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
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;
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
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.
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",
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>
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
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
view release on metacpan or search on metacpan
lib/Text/ZPL.pm view on Meta::CPAN
=head2 decode_zpl
Given a string of C<ZPL>-encoded text, returns an appropriate Perl C<HASH>; an
exception is thrown if invalid input is encountered.
(See L<Text::ZPL::Stream> for a streaming interface.)
=head2 encode_zpl
Given a Perl C<HASH>, returns an appropriate C<ZPL>-encoded text string; an
exception is thrown if the data given cannot be represented in C<ZPL> (see
view release on metacpan or search on metacpan
lib/Thrall/Server.pm view on Meta::CPAN
'psgi.errors' => *STDERR,
'psgi.url_scheme' => $self->{ssl} ? 'https' : 'http',
'psgi.run_once' => Plack::Util::FALSE,
'psgi.multithread' => $self->{is_multithread},
'psgi.multiprocess' => $self->{is_multiprocess},
'psgi.streaming' => Plack::Util::TRUE,
'psgi.nonblocking' => Plack::Util::FALSE,
'psgix.input.buffered' => Plack::Util::TRUE,
'psgix.io' => $conn,
'psgix.harakiri' => Plack::Util::TRUE,
};
view release on metacpan or search on metacpan
t/resolveit view on Meta::CPAN
);
isa_ok( $resolve,'Thread::Pool::Resolve', 'check object type' );
my @thread;
push( @thread,threads->new( \&bythread ) ) foreach 1..10;
$_->join foreach @thread;
$resolve = undef; # needed to finalize streaming in time
ok( check( $resolved,$filtered ), 'check result different threads' );
diag( "Test resolving from Thread::Queue ($optimize)" );
@shared = (@array,undef);
my $queue = bless \@shared,'Thread::Queue';
view release on metacpan or search on metacpan
lib/Thread/Pool.pm view on Meta::CPAN
die "Cannot stream and monitor at the same time"
if exists $self->{ 'stream'};
# Make sure we have a real coderef for the pre and the monitoring routine
# Create a monitored belt
# Set the streaming routine that sends to the monitor
$self->_makecoderef( caller().'::',qw(pre monitor post checkpoint) );
$self->{'monitor_belt'} = Thread::Conveyor::Monitored->new(
{
optimize => $self->{'optimize'},
lib/Thread/Pool.pm view on Meta::CPAN
my $self = shift;
die "Cannot submit jobs on a pool that has been shut down"
if $self->{'shutdown'};
my $belt = $self->{'belt'};
# If we're streaming
# Die now if an individual jobid requested
# Put in box with a jobid obtained on the fly
if ($self->{'stream'}) {
die "Cannot return individual results when streaming"
if defined( wantarray );
$belt->put( $self->_jobid, \@_ );
# Elseif we want a jobid
# Obtain a jobid
lib/Thread/Pool.pm view on Meta::CPAN
} elsif (defined( wantarray )) {
my $jobid = $self->_jobid;
$belt->put( $jobid, \@_ );
return $jobid;
# Else (not streaming and not interested in the result)
# Put in box without a jobid
} else {
$belt->put( \@_ )
}
lib/Thread/Pool.pm view on Meta::CPAN
while (my ($jobid) = $belt->peek_dontwait) {
last if $jobid;
$belt->take;
}
# If we were streaming
# Obtain local copy of stuff we need
if (my $stream = $self->{'stream'}) {
my ($streamid,$jobid,$result) = @$self{qw(streamid jobid result)};
lib/Thread/Pool.pm view on Meta::CPAN
# For all the results that still need to be streamd
# Die if there is no result (_should_ be there by now)
# Call the "stream" routine with this result
# Delete the result from the hash
# Set the stream ID for any further streaming later
for (my $i = $$streamid; $i < $last; $i++) {
die "Cannot find result for streaming job $i"
unless exists( $result->{$i} );
$stream->( @extra,Thread::Serialize::thaw( $result->{$i} ) );
delete( $result->{$i} );
}
$$streamid = $last;
lib/Thread/Pool.pm view on Meta::CPAN
or:
stream => sub {print "anonymous sub called in order of submit\n"},
The "stream" field specifies the subroutine to be executed for streaming the
results of the "do" routine. If specified, the "stream" routine is called
once for the result of each "do" subroutine, but in the order in which the
L<job>s were submitted rather than in the order in which the result were
obtained (which is by the very nature of threads, indeterminate).
lib/Thread/Pool.pm view on Meta::CPAN
1..N the values that were returned by the "do" subroutine
The "monitor" routine is executed in its own thread. This means that all
results have to be passed between threads, and therefore be frozen and thawed
with L<Storable>. If you can handle the streaming from different threads,
it is probably wiser to use the "stream" routine feature.
=item pre_post_monitor_only
pre_post_monitor_only => 1, # default 0
lib/Thread/Pool.pm view on Meta::CPAN
=head2 jobid
$jobid = Thread::Pool->jobid;
The "jobid" class method only makes sense within the "do" subroutine in
streaming mode. It returns the job ID value of the current job. This can
be used connection with the L<dont_set_result> and the L<set_result> methods
to have another thread set the result of the current job.
=head2 dont_set_result
view release on metacpan or search on metacpan
bench/big_test_data view on Meta::CPAN
streaks
stream
streamed
streamer
streamers
streaming
streamline
streamlined
streamliner
streamlines
streamlining
view release on metacpan or search on metacpan
Revision history for Tie-Handle-TtyRec
0.04 2012-03-06
allow streaming to named pipes (Jesse Luehrs)
allow appending (Jesse Luehrs)
fix error message (Jesse Luehrs)
allow syswrite to work on these handles (Jesse Luehrs)
0.03 Sun Jun 14 14:59:00 2009