Result:
found more than 672 distributions - search limited to the first 2001 files matching your query
( run in 1.334 )
Tail-Stat
view release on metacpan or search on metacpan
lib/Tail/Stat/Plugin/icecast.pm view on Meta::CPAN
package Tail::Stat::Plugin::icecast;
=head1 NAME
Tail::Stat::Plugin::icecast - Statistics collector for Icecast streaming server
=cut
use strict;
use warnings 'all';
Tangence
view release on metacpan or search on metacpan
doc/02-datamodel.txt view on Meta::CPAN
2. Data Model
-------------
Whenever a value is sent across the connection between the server and a
client, that value has a fixed type. The underlying streaming layer
recognises the following fundamental types of values. Each type has a
string to identify call it, called the signature. These are used by
introspection data; see later.
* Booleans
Tatsumaki-Service-XMPP
view release on metacpan or search on metacpan
lib/Tatsumaki/Service/XMPP.pm view on Meta::CPAN
$env->{'tatsumaki.xmpp'} = {
client => $client,
account => $acct,
message => $msg,
};
$env->{'psgi.streaming'} = 1;
my $res = $self->application->($env);
$res->(sub { my $res = shift }) if ref $res eq 'CODE';
},
contact_request_subscribe => sub {
lib/Tatsumaki/Service/XMPP.pm view on Meta::CPAN
$env->{'tatsumaki.xmpp'} = {
client => $client,
account => $acct,
contact => $contact,
};
$env->{'psgi.streaming'} = 1;
my $res = $self->application->($env);
$res->(sub { my $res = shift }) if ref $res eq 'CODE';
},
);
Tatsumaki
view release on metacpan or search on metacpan
lib/Tatsumaki.pm view on Meta::CPAN
Tatsumaki is a toy port of Tornado for Perl using Plack (with
non-blocking extensions) and AnyEvent.
It allows you to write a web application that does a immediate
response with template rendering, IO-bound delayed response (like
fetching third party API or XML feeds), server push streaming and
long-poll Comet in a clean unified API.
=head1 PSGI COMPATIBILITY
When C<asynchronous> is declared in your application, you need a PSGI
server backend that supports C<psgi.streaming> response style. If your
application does server push with C<stream_write>, you need a server
that supports C<psgi.nonblocking> (and C<psgi.streaming>) as well.
Currently Tatsumaki asynchronous application is supposed to run on
L<Twiggy>, L<Feersum>, L<Corona> and L<POE::Component::Server::PSGI>.
If C<asynchronous> is not used, your application is supposed to run in
Template-Alloy
view release on metacpan or search on metacpan
off STREAM since the WRAPPERS are generated in reverse order and
because the content is inserted into the middle of the WRAPPERS.
WRAPPERS will still work, they just won't stream.
VARIOUS errors
Because the template is streaming, items that cause errors my
result in partially printed pages - since the error would occur
part way through the print.
All output is printed directly to the currently selected filehandle
(defaults to STDOUT) via the CORE::print function. Any output
Term-CLI
view release on metacpan or search on metacpan
benchmarks/wordlist-en.txt view on Meta::CPAN
institutists
institutive
institutively
institutor
institutors
instreaming
instreamings
instress
instressed
instresses
instressing
instroke
benchmarks/wordlist-en.txt view on Meta::CPAN
mainsprings
mainstay
mainstays
mainstream
mainstreamed
mainstreaming
mainstreamings
mainstreams
mainstreeting
mainstreetings
maintain
maintainabilities
benchmarks/wordlist-en.txt view on Meta::CPAN
slipslops
slipsole
slipsoles
slipstream
slipstreamed
slipstreaming
slipstreams
slipt
slipup
slipups
slipware
benchmarks/wordlist-en.txt view on Meta::CPAN
streamers
streamier
streamiest
streaminess
streaminesses
streaming
streamingly
streamings
streamless
streamlet
streamlets
streamlike
streamline
benchmarks/wordlist-en.txt view on Meta::CPAN
upstirring
upstirs
upstood
upstream
upstreamed
upstreaming
upstreams
upstretched
upstroke
upstrokes
upsurge
Terse
view release on metacpan or search on metacpan
lib/Terse.pm view on Meta::CPAN
insecure_session => 0,
content_type => 'application/json',
request_class => 'Plack::Request',
websocket_class => 'Terse::WebSocket',
sock => 'psgix.io',
stream_check => 'psgi.streaming',
favicon => 'favicon.ico',
%args
);
$j->_build_terse();
lib/Terse.pm view on Meta::CPAN
=cut
=head2 delayed_response
Delay the response for non-blocking I/O based server streaming or long-poll Comet push technology.
$terse->delayed_response(sub {
$terse->response->test = 'okay';
return $terse->response;
});
Test-Catch
view release on metacpan or search on metacpan
#include <iostream>
#include <catch2/catch_session.hpp>
#include <catch2/internal/catch_string_manip.hpp>
#include <catch2/internal/catch_console_colour.hpp>
#include <catch2/reporters/catch_reporter_registrars.hpp>
#include <catch2/reporters/catch_reporter_streaming_base.hpp>
#include <xsheader.h>
using namespace Catch;
using namespace std;
Test-HTTP-LocalServer
view release on metacpan or search on metacpan
lib/Test/HTTP/gzip-streamed.psgi view on Meta::CPAN
our $VERSION = '0.67';
my $app = sub {
my $env = shift;
die "This app needs a server that supports psgi.streaming"
unless $env->{'psgi.streaming'};
die "The client did not send the 'Accept-Encoding: gzip' header"
unless defined $env->{HTTP_ACCEPT_ENCODING}
&& $env->{HTTP_ACCEPT_ENCODING} =~ /\bgzip\b/;
# Note some browsers don't correctly support gzip correctly,
# see e.g. https://metacpan.org/pod/Plack::Middleware::Deflater
Test-Mojo-Plack
view release on metacpan or search on metacpan
lib/Test/Mojo/Plack.pm view on Meta::CPAN
'psgi.input' => IO::String->new($tx->req->body . "\r\n"),
'psgi.errors' => *STDERR,
'psgi.multithread' => 0,
'psgi.multiprocess' => 0,
'psgi.run_once' => 1,
'psgi.streaming' => 1,
'psgi.nonblocking' => 0,
'HTTP_CONTENT_LENGTH' => length($tx->req->body),
};
for my $field ( @{ $tx->req->headers->names || [] }) {
Test-Mojo-Role-PSGI
view release on metacpan or search on metacpan
0.05 2015-11-17
- Added more realistic Catalyst tests (nicomen)
- Bump verion of MountPSGI to 0.07 (request body handling)
0.04 2015-11-15
- Added Catalyst tests (if available) (nicomen)
- Bump verion of MountPSGI to 0.05 (delayed/streaming)
0.03 2015-06-06
- Fix a typo in cpanfile
0.02 2015-06-03
- Now a little more flexible in what is accepted as a psgi app
- Bump version of MountPSGI to 0.04
Test-Parser
view release on metacpan or search on metacpan
scripts/parse_iozone view on Meta::CPAN
# If the user has specified multi-record operation, we can't
# rely on T:P:iozone's file open code and must work with
# streams, because we'll be creating multiple T:P:iozone
# objects per file.
# Open the file for streaming
if (ref($input)) {
$input_stream = $input;
warn "Parsing input stream...\n" if $opt_debug>0;
} elsif (-f $input) {
if (! open(FILE, "<$input")) {
Test-Perinci-CmdLine
view release on metacpan or search on metacpan
lib/Test/Perinci/CmdLine.pm view on Meta::CPAN
},
],
}, # tx
{
name => 'streaming',
before_all_tests => sub {
write_text("$tempdir/infile-str", "one\ntwo three\nfour\n");
write_text("$tempdir/infile-hash-json", qq({}\n{"a":1}\n{"b":2,"c":3}\n{"d":4}\n));
write_text("$tempdir/infile-invalid-json", qq({}\n{\n));
write_text("$tempdir/infile-int", qq(1\n3\n5\n));
write_text("$tempdir/infile-invalid-int", qq(1\nx\n5\n));
write_text("$tempdir/infile-words", qq(word1\nword2\n));
write_text("$tempdir/infile-invalid-words", qq(word1\nword2\nnot a word\n));
},
tests => [
# streaming input
{
tags => ['streaming', 'streaming-input'],
name => "stream input, simple type, chomp on",
gen_args => {url => '/Perinci/Examples/Stream/count_lines'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["$tempdir/infile-str"],
stdout_like => qr/
3
/mx,
},
{
tags => ['streaming', 'streaming-input'],
name => "stream input, simple type, chomp off",
gen_args => {url => '/Perinci/Examples/Stream/wc'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["$tempdir/infile-str"],
stdout_like => qr/
lib/Test/Perinci/CmdLine.pm view on Meta::CPAN
^lines \s+ 3\n
^words \s+ 4\n
/mx,
},
{
tags => ['streaming', 'streaming-input'],
name => "stream input, json stream",
gen_args => {url => '/Perinci/Examples/Stream/wc_keys'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["$tempdir/infile-hash-json"],
stdout_like => qr/^keys \s+ 4\n/mx,
},
{
tags => ['streaming', 'streaming-input', 'validate-streaming-input'],
name => 'stream input, simple type, word validation', # also test that each record is chomp-ed
gen_args => {url => '/Perinci/Examples/Stream/count_words'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["$tempdir/infile-words"],
stdout_like => qr/2/,
},
{
tags => ['streaming', 'streaming-input', 'validate-streaming-input'],
name => 'stream input, simple types, word validation, error',
gen_args => {url => '/Perinci/Examples/Stream/count_words'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["$tempdir/infile-invalid-words"],
exit_code_like => qr/[1-9]/,
stderr_like => qr/fails validation/,
},
{
tags => ['streaming', 'streaming-input', 'validate-streaming-input'],
name => 'stream input, simple types, word validation, error',
gen_args => {url => '/Perinci/Examples/Stream/count_words'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["$tempdir/infile-invalid-words"],
exit_code_like => qr/[1-9]/,
stderr_like => qr/fails validation/,
},
{
tags => ['streaming', 'streaming-input', 'validate-streaming-input'],
name => 'stream input, json stream, error',
gen_args => {url => '/Perinci/Examples/Stream/wc_keys'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["$tempdir/infile-invalid-json"],
exit_code => 200,
},
# streaming result
{
tags => ['streaming', 'streaming-result', 'validate-streaming-result'],
name => "stream result, simple types, word validation",
gen_args => {url => '/Perinci/Examples/Stream/produce_words_err'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["-n", 9],
},
{
tags => ['streaming', 'streaming-result', 'validate-streaming-result'],
name => "stream result, simple types, word validation, error",
gen_args => {url => '/Perinci/Examples/Stream/produce_words_err'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["-n", 10],
exit_code_like => qr/[1-9]/,
stderr_like => qr/fails validation/,
},
{
tags => ['streaming', 'streaming-result'],
name => "stream result, json stream",
gen_args => {url => '/Perinci/Examples/Stream/produce_hashes'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => [qw/-n 3/],
stdout_like => qr/
lib/Test/Perinci/CmdLine.pm view on Meta::CPAN
^\Q{"num":2}\E\n
^\Q{"num":3}\E\n
/mx,
},
# streaming input+result
{
tags => ['streaming', 'streaming-input', 'streaming-result'],
name => "stream input+result, simple type, float validation",
gen_args => {url => '/Perinci/Examples/Stream/square_nums'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["$tempdir/infile-int"],
stdout_like => qr/
lib/Test/Perinci/CmdLine.pm view on Meta::CPAN
^"?9"?\n
^"?25"?\n
/mx,
},
{
tags => ['streaming', 'streaming-input', 'streaming-result', 'validate-streaming-input'],
name => "stream input+result, simple type, float validation, error",
gen_args => {url => '/Perinci/Examples/Stream/square_nums'},
inline_gen_args => {load_module=>["Perinci::Examples::Stream"]},
argv => ["$tempdir/infile-invalid-int"],
exit_code_like => qr/[1-9]/, # sometimes it's 9, sometimes it's 25; looks like the input line is being used somehow as exit code?
stderr_like => qr/fails validation/,
},
],
}, # streaming
{
name => 'result metadata',
tests => [
{
Test-Text
view release on metacpan or search on metacpan
data/en_US.dic view on Meta::CPAN
streaker/M
streaky/TR
stream/GZSMDR
streamed/U
streamer/M
streaming/M
streamline/SRDGM
street/SMZ
streetcar/MS
streetlight/SM
streetwalker/MS
Test2-Harness-UI
view release on metacpan or search on metacpan
- Stop using seperate field tables
- Fix closing columns rendering issue
0.000011 2019-08-22 08:55:11-07:00 America/Los_Angeles
- Further break up the jobs data for streaming
0.000010 2019-08-21 23:31:56-07:00 America/Los_Angeles
- Add a favicon
0.000009 2019-08-21 22:35:49-07:00 America/Los_Angeles
- Better streaming of jobs
0.000008 2019-08-21 19:47:01-07:00 America/Los_Angeles
- Add missing version numbers
- Do not include the demo dir in the tarball
Text-APL
view release on metacpan or search on metacpan
lib/Text/APL.pm view on Meta::CPAN
=pod
=head1 NAME
Text::APL - non-blocking and streaming capable template engine
=head1 SYNOPSIS
=head2 Simple example
lib/Text/APL.pm view on Meta::CPAN
);
=head1 DESCRIPTION
This is yet another template engine. But compared to others it supports
non-blocking (read/write) and streaming output.
=head2 Reader/Writer
Reader and writer can be a subroutine references reading from any source and
writing output to any destination. Sane default implementations for reading from
lib/Text/APL.pm view on Meta::CPAN
=head2 Compiler
Compiler compiles templates into Perl code but when evaluating does not create
a Perl string that accumulates all the template output, but rather provides
a special C<print> function that pushes the content as soon as it's available
(streaming).
The generated Perl code can looks like this:
Hello, <%= $nickname %>!
Text-ASCIIPipe
view release on metacpan or search on metacpan
lib/Text/ASCIIPipe.pm view on Meta::CPAN
,allend => \&allend_hook
);
=head1 DESCRIPTION
A lot of the speed penalty of Perl when processing multiple smallish data sets from/to text form in a shell loop consists of the repeated perl compiler startup / script compilation, which accumulates when looping over a set of files. This process can...
When dealing with ASCII-based text files (or UTF-8, if you please), there are some control characters that just make sense for pushing several files as a stream, separated by these characters. These are character codes 2 (STX, start of text), 3 (EOT,...
All this module does is provide a wrapper for inserting these control characters for the sender and parsing them for the receiver. Nothing fancy, really. I just got fed up writing the same loop over and over again. It works with all textual data that...
The process() function itself tries to employ a bit of smartness regarding buffering of the output. Since the actual operation of multiple ASCIIPipe-using programs in a, well, pipe, might conflict with the default buffering of the output stream (STDO...
Text-BIP
view release on metacpan or search on metacpan
lib/Text/BIP.pm view on Meta::CPAN
}
}
1;
}
# accessors methods to current state while streaming.
sub dir { $_[0]->{__stack}->[-1]->{path} || $path_delim; }
sub relative_dir {
my $base = $_[1] || $_[0]->base;
$_[0]->{__stack}->[-1]->{path}=~m/^$base(.*)/ ? $1 : '';
}
Text-CSV
view release on metacpan or search on metacpan
lib/Text/CSV.pm view on Meta::CPAN
my @list; # List of hashes
csv (in => $_, out => \@list, bom => 1) for sort glob "foo-[0-9]*.csv";
=head4 Streaming
If B<both> C<in> and C<out> are files, file handles or globs, streaming is
enforced by injecting an C<after_parse> callback that immediately uses the
L<C<say ()>|/say> method of the same instance to output the result and then
rejects the record.
If a C<after_parse> was already passed as attribute, that will be included
Text-CSV_XS
view release on metacpan or search on metacpan
}
else {
$cbai = sub { $_[0]->say ($fho, $_[1]); 0 };
}
# Put all callbacks back in place for streaming behavior
$attr{'callbacks'}{'after_parse'} = $cbai; $cbai = undef;
$attr{'callbacks'}{'before_out'} = $cbbo; $cbbo = undef;
$attr{'callbacks'}{'on_in'} = $cboi; $cboi = undef;
$attr{'callbacks'}{'on_error'} = $cboe; $cboe = undef;
$out = undef;
my @list; # List of hashes
csv (in => $_, out => \@list, bom => 1) for sort glob "foo-[0-9]*.csv";
=head4 Streaming
X<streaming>
If B<both> C<in> and C<out> are files, file handles or globs, streaming is
enforced by injecting an C<after_parse> callback that immediately uses the
L<C<say ()>|/say> method of the same instance to output the result and then
rejects the record.
If a C<after_parse> was already passed as attribute, that will be included
}
# using the csv function, all in memory
csv (out => "foo.csv", in => $dbh->selectall_arrayref ($sql));
# using the csv function, streaming with callbacks
my $sth = $dbh->prepare ($sql); $sth->execute;
csv (out => "foo.csv", in => sub { $sth->fetch });
csv (out => "foo.csv", in => sub { $sth->fetchrow_hashref });
Note that this does not discriminate between "empty" values and NULL-values
Text-FillIn
view release on metacpan or search on metacpan
=head1 DESCRIPTION
This module provides a class for doing fill-in templates. These templates may be used
as web pages with dynamic content, e-mail messages with fill-in fields, or whatever other
uses you might think of. B<Text::FillIn> provides handy methods for fetching files
from the disk, printing a template while interpreting it (also called streaming),
and nested fill-in sections (i.e. expressions like [[ $th[[$thing2]]ing1 ]] are legal).
Note that the version number here is 0.04 - that means that the interface may change
a bit. In fact, it's already changed some with respect to 0.02 (see the CHANGES file).
In particular, the $LEFT_DELIM, $RIGHT_DELIM, %HOOK, and @TEMPLATE_PATH variables are
This, along with interpret_and_print, are the main point of this whole module.
=item * $template->interpret_and_print()
Interprets the [[ fill-in parts ]] of a template and prints the template,
streaming its output as much as possible. This means that if it encounters
an expression like "[[ stuff [[ more stuff]] ]]", it will fill in [[ more stuff ]],
then use the filled-in value to resolve the value of [[ stuff something ]],
and then print it out.
If it encounters an expression like "stuff1 [[thing1]] stuff2 [[thing2]]",
Text-Hoborg
view release on metacpan or search on metacpan
data/en_US.dic view on Meta::CPAN
streaker/M
streaky/TR
stream/GZSMDR
streamed/U
streamer/M
streaming/M
streamline/SRDGM
street/SMZ
streetcar/MS
streetlight/SM
streetwalker/MS
Text-JSON-Nibble
view release on metacpan or search on metacpan
lib/Text/JSON/Nibble.pm view on Meta::CPAN
our $VERSION = '1.01';
=head1 WARNING
This module should be used with caution, it will not handle 'badly formed' json well, its entire purpose was because I was experiencing
segfaults with Cpanel::XS's decode_prefix when dealing with a streaming socket buffer.
=head1 DESCRIPTION
This module is a 'character' crawling JSON extractor for plain TEXT, usable in both a 'streaming' or 'block' method, for when you need something that is not XS.
It is particularly handy for when you want to deal with JSON without decoding it.
=head1 SYNOPSIS
lib/Text/JSON/Nibble.pm view on Meta::CPAN
=head2 digest
Digest the text that is fed in and attempt to return a complete an array of JSON object from it, returns either a blank array or an array of text-encoded-json.
Note you can call and use this at any time, even if you are using streaming functionality.
=cut
sub digest {
my $self = shift;
Text-MarkdownTable
view release on metacpan or search on metacpan
lib/Text/MarkdownTable.pm view on Meta::CPAN
has condense => (
is => 'rw',
);
has streaming => (is => 'rwp');
has _fixed_width => (is => 'rw', default => sub { 1 });
# TODO: duplicated in Catmandu::Exporter::CSV fields-coerce
sub _coerce_list {
lib/Text/MarkdownTable.pm view on Meta::CPAN
}
my $fields = $self->fields;
my $widths = $self->widths; # may set
my $row = [ ];
if (!$self->streaming and ($self->condense or $self->_fixed_width)) {
$self->_set_streaming(1);
$self->_print_header if $self->header;
}
foreach my $col (0..(@$fields-1)) {
my $field = $fields->[$col];
lib/Text/MarkdownTable.pm view on Meta::CPAN
}
sub _add_row {
my ($self, $row) = @_;
if ($self->streaming) {
$self->_print_row($row);
} else {
push @{$self->{_rows}}, $row;
}
}
lib/Text/MarkdownTable.pm view on Meta::CPAN
=item add( $row )
Add a row as hash reference. Returns the table instance.
=item streaming
Returns whether rows are directly written or buffered until C<done> is called.
=item done
Finish and write the table unless it has already been written in C<streaming>
mode.
=back
=head1 SEE ALSO
Text-NSR
view release on metacpan or search on metacpan
lib/Text/NSR.pm view on Meta::CPAN
=head1 AUTHOR
Clipland GmbH L<https://www.clipland.com/>
This module was developed for L<live streaming|https://instream.de/> infotainment website L<InStream.de|https://instream.de/>.
=head1 COPYRIGHT & LICENSE
Copyright 2022 Clipland GmbH. All rights reserved.
Text-Scan
view release on metacpan or search on metacpan
t/57_breakme-multi.t view on Meta::CPAN
"killed",
"label",
"legalization",
"life styles",
"local authorities",
"mainstreaming",
"malnutrition",
"market reform",
"market reforms",
"medical treatment",
"medical treatments",
Text-SenseClusters
view release on metacpan or search on metacpan
Testing/preprocess/plain/text2sval/test-A1.reqd view on Meta::CPAN
</context>
</instance>
<instance id="line-n.w7_114:9011:">
<answer instance="line-n.w7_114:9011:" senseid="formation"/>
<context>
the ghost town at knott's berry farm theme park is usually a pretty cheery place bustling with cowboys staging shootouts on the storefront boardwalks folks buying souvenirs and snacks from calico clad shopkeepers and <head>lines</head> streaming ont...
</context>
</instance>
<instance id="line-n.w7_088:11840:">
<answer instance="line-n.w7_088:11840:" senseid="formation"/>
<context>
Text-Summarizer
view release on metacpan or search on metacpan
Corpus/written/ficlets/1402.txt view on Meta::CPAN
Sequels: none
I like games.
I started playing my games because of people like Jenna. Middle school was cruel, full of disgusting, stinking children. Hardly a place for the likes of me, but nobody ever did a thing about it.
The thing that set me off at first was her hair; it was long and shiny and blonde. Every time somebody spoke to her, she tossed it over her shoulder, rivers of gold streaming down her back. Practically taunting me and my scissors. After a few weeks o...
I recall how she cried when I chopped it all off with messy, rough snips. I remember her straw-hair wound tightly around her neck; I didn’t need any rope. Tipping over the chair and putting a match to the boyish mess that was the rest of her hair.....
Want to play a game with me? There are only a few rules. First, you must play along. Second, don’t try to escape. Oh, and third, I always win.
Frantic Panic
Text-Textile-Plaintext
view release on metacpan or search on metacpan
lib/App/Textile2x.pm view on Meta::CPAN
=item Filehandle reference (GLOB)
Lastly, if the source is a filehandle or filehandle-like value, it is read from
and the complete content from it is passed to B<Text::Textile>. Note that it is
not I<streamed> to the Textile converter (which does not support streaming
anyway). Caution should be taken when converting excessively large files this
way.
=back
( run in 1.334 second using v1.01-cache-2.11-cpan-4d50c553e7e )