view release on metacpan or search on metacpan
int nrows = PQntuples(res);
int ncols = PQnfields(res);
AV *rows = newAV();
int r, c;
/* Defer metadata building until result_meta is called.
* In streaming mode, capture only the first result per query
* (meta_fresh is cleared by advance_cb_queue). */
if (st == PGRES_TUPLES_OK || !self->meta_fresh) {
RELEASE_LAST_HV(self->last_result_meta);
self->meta_fresh = 1;
}
view release on metacpan or search on metacpan
eg/backpressure.pl view on Meta::CPAN
my $port = $ctx->listen(
port => 0,
on_connect => sub {
my ($c) = @_;
print "Server: client connected, streaming $TARGET_MSGS chunks of ${\ ($CHUNK_SIZE/1024)}KB\n";
$c->stash->{sent} = 0;
$t0 = time;
try_send($c);
},
on_drain => sub {
view release on metacpan or search on metacpan
lib/EEDB/Edge.pm view on Meta::CPAN
}
###############################################################################################
#
# streaming API section
#
###############################################################################################
=head2 stream_all
view release on metacpan or search on metacpan
lib/Elive/Util.pm view on Meta::CPAN
sub _tainted {
return grep { Scalar::Util::tainted($_) } @_;
}
#
# Hex encoding/decoding. Use for data streaming. E.g. upload & download
# of preload data.
#
sub _hex_decode {
my $data = shift;
view release on metacpan or search on metacpan
lib/Email/LocalDelivery/Mbox.pm view on Meta::CPAN
my $fh = $class->_open_fh($file) or next;
print $fh "\n" if tell($fh) > 0;
print $fh $class->_from_line($email);
print $fh $class->_escape_from_body($email);
# This will make streaming a bit more annoying. -- rjbs, 2007-05-25
print $fh "\n" unless $email->as_string =~ /\n$/;
$class->_close_fh($fh) || next;
push @rv, $file;
}
view release on metacpan or search on metacpan
lib/Email/Sender/Transport/SMTPS.pm view on Meta::CPAN
message => $message,
failures => \@failures,
);
}
# restore Pobox's support for streaming, code-based messages, and arrays here
# -- rjbs, 2008-12-04
$smtp->data or $FAULT->("error at DATA start");
my $msg_string = $email->as_string;
view release on metacpan or search on metacpan
lib/Email/Sender/Transport/Mbox.pm view on Meta::CPAN
or Carp::confess("couldn't write to $filename: $!");
$fh->print($self->_escape_from_body($email))
or Carp::confess("couldn't write to $filename: $!");
# This will make streaming a bit more annoying. -- rjbs, 2007-05-25
$fh->print("\n")
or Carp::confess("couldn't write to $filename: $!")
unless $email->as_string =~ /\n$/;
$self->_close_fh($fh)
view release on metacpan or search on metacpan
allow header_class arg to new(), to match Email::Simple's new (HDP)
0.050 2007-02-06
excellent features added by HDP:
test for reading from unseekable filehandles
add getline() for streaming from an email
add stream_to() for convenient streaming to a fh (or anything else)
0.011 2006-06-13
added this changelog
view release on metacpan or search on metacpan
lib/EntityModel/Web/PSGI.pm view on Meta::CPAN
context => $ctx,
page => $ctx->page,
request => $req,
);
# then ignore it and generate the body and a hardcoded 200 return
# FIXME use proper status code here and support streaming/async!
my $body = $ctx->process;
return $self->psgi_result(
$env,
200,
[ 'Content-Type' => 'text/html' ],
lib/EntityModel/Web/PSGI.pm view on Meta::CPAN
=head2 psgi_result
Returns an appropriate PSGI response, either
an arrayref or a coderef depending on server
support for async/streaming.
=cut
sub psgi_result {
my $self = shift;
my ($env, $rslt, $hdr, $body) = @_;
logInfo("Streaming: %s", $env->{'psgi.streaming'} ? 'yes' : 'no');
return [ $rslt, $hdr, [ $body ] ] unless $env->{'psgi.streaming'};
return sub {
my $responder = shift;
my $writer = $responder->([
$rslt,
view release on metacpan or search on metacpan
lib/Etcd3.pm view on Meta::CPAN
$range = $etcd->range({ key =>'test0', range_end => 'test100' });
# return array { key => value } pairs from range request.
my @users = $range->all
# watch key range, streaming.
$watch = $etcd->watch( { key => 'foo', range_end => 'fop'}, sub {
my ($result) = @_;
print STDERR Dumper($result);
})->create;
view release on metacpan or search on metacpan
lib/Eve/PsgiStub.pm view on Meta::CPAN
'QUERY_STRING' => $query,
'SERVER_SIGNATURE' => '<address>Apache/2.2.20 Port 80</address>',
'HTTP_CACHE_CONTROL' => 'max-age=0',
'HTTP_ACCEPT_LANGUAGE' => 'en-us,en;q=0.7,ru;q=0.3',
'HTTP_X_REAL_IP' => '127.0.0.1',
'psgi.streaming' => 1,
'MOD_PERL_API_VERSION' => 2,
'PATH' => '/usr/local/bin:/usr/bin:/bin',
'GATEWAY_INTERFACE' => 'CGI/1.1',
'psgi.version' => [ 1, 1 ],
'DOCUMENT_ROOT' => '/var/www/some/other/path',
view release on metacpan or search on metacpan
lib/FCGI/Async/PSGI.pm view on Meta::CPAN
'psgi.errors' => $req->stderr,
'psgi.multithread' => 0,
'psgi.multiprocess' => 0,
'psgi.run_once' => 0,
'psgi.nonblocking' => 1,
'psgi.streaming' => 1,
# Extensions
'fcgi.async' => $self,
'fcgi.async.req' => $req,
'fcgi.async.loop' => $self->get_loop,
view release on metacpan or search on metacpan
lib/FCGI/Engine/PSGI.pm view on Meta::CPAN
'psgi.errors' => *STDERR, # FCGI.pm redirects STDERR in Accept() loop, so just print STDERR
# print to the correct error handle based on keep_stderr
'psgi.multithread' => Plack::Util::FALSE,
'psgi.multiprocess' => Plack::Util::TRUE,
'psgi.run_once' => Plack::Util::FALSE,
'psgi.streaming' => Plack::Util::TRUE,
'psgi.nonblocking' => Plack::Util::FALSE,
};
};
sub handle_request {
view release on metacpan or search on metacpan
lib/FFmpeg/Stream/Helper.pm view on Meta::CPAN
use base 'Error::Helper';
use String::ShellQuote;
=head1 NAME
FFmpeg::Stream::Helper - Helper for streaming and transcoding using ffmpeg.
=head1 VERSION
Version 0.1.1
lib/FFmpeg/Stream/Helper.pm view on Meta::CPAN
our $VERSION = '0.1.1';
=head1 SYNOPSIS
This module is for helping generate a command for ffmpeg that should be good for streaming to HTML5.
This module also does it securely by using String::ShellQuote for every definable option passed to ffmpeg.
# Defaults Are...
# Output: - ((standard out))
view release on metacpan or search on metacpan
=item I<ffserver>
an HTTP (RTSP is being developped) multimedia
streaming server for live broadcasts. Time shifting of
live broadcast is also supported.
=item I<ffplay>
a simple media player based on SDL and on the ffmpeg libraries.
view release on metacpan or search on metacpan
deps/libcbor/src/cbor/ints.h
deps/libcbor/src/cbor/maps.c
deps/libcbor/src/cbor/maps.h
deps/libcbor/src/cbor/serialization.c
deps/libcbor/src/cbor/serialization.h
deps/libcbor/src/cbor/streaming.c
deps/libcbor/src/cbor/streaming.h
deps/libcbor/src/cbor/strings.c
deps/libcbor/src/cbor/strings.h
deps/libcbor/src/cbor/tags.c
deps/libcbor/src/cbor/tags.h
deps/libfido2/LICENSE
view release on metacpan or search on metacpan
Gzip compression can be done with a few different libraries. The canonical one
is I<zlib>, which is old and not well optimized for modern systems. There's
also I<zlib-ng>, a (much) more performant reimplementation that remains
API-compatible with I<zlib>. And there's I<libdeflate>, which offers a
different API that does not support streaming compression but is, in exchange,
even faster than I<zlib-ng>.
There are more implementations, of course, but this module only supports those
three and (attempts to) pick the best one that's available on your system.
This function is B<NOT> safe to use from multiple threads!
=back
This module does not currently implement decompression. If you need that, or
streaming, or other functionality not provided here, there's
L<Compress::Raw::Zlib> and L<Compress::Zlib> in the core Perl distribution and
L<Gzip::Faster>, L<Gzip::Zopfli> and L<Gzip::Libdeflate> on CPAN.
=head1 Brotli Compression
view release on metacpan or search on metacpan
eg/oneshot.pl view on Meta::CPAN
my $evh = Feersum->new();
$evh->use_socket($socket);
$evh->request_handler(sub {
my $r = shift;
my $n = "only";
my $w = $r->start_streaming("200 OK", [
'Content-Type' => 'text/plain',
'Connection' => 'close',
]);
$w->write("Hello customer number ");
$w->write(\$n);
view release on metacpan or search on metacpan
1.0.0 Sun Aug 7 15:23:36 CDT 2005
- finished test suite
- fixed bug to allow 'read' to be called on an existing RIFF object
- document RIFF::read usage as a method
- added eg/socketpair.pl (example streaming a RIFF over a socket)
0.9.4 Sun Aug 7 12:56:13 CDT 2005
- more testing
- document 'total_size' and RIFF::write
- other minor fixes to documentation
view release on metacpan or search on metacpan
examples/pretty_print_a_directory_using_as_tree.pl view on Meta::CPAN
# The fool-proof, dead-simple way to pretty-print a directory tree. Caveat:
# This isn't a method for massive directory traversal, and is subject to the
# limitations inherent in stuffing an entire directory tree into RAM. Go
# back and use bare callbacks (see other examples) if you need a more efficient,
# streaming (real-time) pretty-printer where top-level sorting is less
# important than resource constraints and speed of execution.
# set this to the name of the directory to pretty-print
my $treetrunk = '.';
view release on metacpan or search on metacpan
examples/raven.pl view on Meta::CPAN
sitting, still is sitting
On the pallid bust of Pallas just above
my chamber door;
And his eyes have all the seeming of a
demon's that is dreaming,
And the lamp-light o'er him streaming
throws his shadow on the floor;
And my soul from out that shadow that
lies floating on the floor
Shall be lifted--nevermore!
EOF
view release on metacpan or search on metacpan
lib/Finance/Alpaca/Struct/Order.pm view on Meta::CPAN
Alpaca. Each order has a unique identifier provided by the client. This
client-side unique order ID will be automatically generated by the system if
not provided by the client, and will be returned as part of the order object
along with the rest of the fields described below. Once an order is placed, it
can be queried using the client-side order ID to check the status. Updates on
open orders at Alpaca will also be sent over the streaming interface, which is
the recommended method of maintaining order state.
=head1 Properties
The following properties are contained in the object.
view release on metacpan or search on metacpan
lib/Finance/Bitcoin/Feed.pm view on Meta::CPAN
__END__
=head1 NAME
Finance::Bitcoin::Feed - Collect bitcoin real-time price from many sites' streaming data source
=head1 SYNOPSIS
use Finance::Bitcoin::Feed;
view release on metacpan or search on metacpan
CompanyNames/TextSupport.pm view on Meta::CPAN
mainland mainlander mainlanders
mainline mainliners mainlines
mainlobe mainlobes
mainstay mainstays
mainstem mainstems
mainstream mainstreamed mainstreamer mainstreamers mainstreaming mainstreams
maintain maintainability maintainable maintained maintainer maintainers maintaining maintains
maison maisons
majestatis majestic majestically majesties majesty
major majored majoring majorities majority majors
majorette majorettes
CompanyNames/TextSupport.pm view on Meta::CPAN
stratosphere stratospheric
straw strawed straws
strawberries strawberry
stray strayed straying strays
streak streaked streaker streakers streaking streaks
stream streamed streaming streams
streambank streambanks
streambed streambeds
streamer streamers
streamflow streamflows
streamline streamlined streamliner streamliners streamlines streamlining
CompanyNames/TextSupport.pm view on Meta::CPAN
streaks
stream
streamed
streamer
streamers
streaming
streamline
streamlined
streamliner
streamlines
streamlining
view release on metacpan or search on metacpan
lib/Finance/IG.pm view on Meta::CPAN
# "market" : {
# "lotSize" : 1,
# "marketStatus" : "EDITS_ONLY",
# "instrumentType" : "SHARES",
# "expiry" : "DFB",
# "streamingPricesAvailable" : false,
# "instrumentName" : "Regeneron Pharmaceuticals Inc",
# "offer" : 60261,
# "delayTime" : 0,
# "updateTime" : "20:59:56",
# "high" : 61455,
view release on metacpan or search on metacpan
lib/Flat/Profile.pm view on Meta::CPAN
max_errors => 1000,
);
=head1 DESCRIPTION
Flat::Profile is part of the Flat::* series. It provides streaming-first profiling
for CSV/TSV inputs for practical ETL and legacy data workflows.
Design goals:
=over 4
lib/Flat/Profile.pm view on Meta::CPAN
=head2 profile_file
my $report = $p->profile_file(%args);
Profiles a CSV/TSV file in a streaming pass and returns a hashref report.
Key named arguments include:
=over 4
view release on metacpan or search on metacpan
use Test::TCP;
use version;
use Exporter 'import';
our $ENABLE_TEST_EVENT_TIME;
our @EXPORT_OK = qw/ streaming_decode_mp run_fluentd slurp_log $ENABLE_TEST_EVENT_TIME /;
sub streaming_decode_mp {
my $sock = shift;
my $offset = 0;
my $up = Data::MessagePack::Unpacker->new;
while( read($sock, my $buf, 1024) ) {
$offset = $up->execute($buf, $offset);
view release on metacpan or search on metacpan
share/passwords.txt view on Meta::CPAN
treble
tralala
tigercat
tarakan
sunlight
streaming
starr
sonysony
smart1
skylark
sites
view release on metacpan or search on metacpan
lang_en/conceptnet-commonsense-is-1.pro view on Meta::CPAN
is <> a very fine <> material <> leather <> <> <> nothing <> <> <> <> 50
is <> junks <> ships <> <> <> <> nothing <> <> <> <> 50
is <> hockey <> a popular sport <> in canada <> <> <> nothing <> <> <> <> 50
is <> plants <> nothing <> for the environment;good <> <> <> nothing <> <> <> <> 50
is <> steel <> a metal <> <> <> <> nothing <> <> <> <> 50
is streaming <> a website <> video <> <> <> <> nothing <> <> <> <> 50
going is <> a <> nothing <> to france;traveler <> <> <> nothing <> <> <> <> 50
is <> a tool <> a object <> <> <> <> nothing <> <> <> <> 50
is <> the egret <> a bird <> <> <> <> nothing <> <> <> <> 50
is <> tanks <> largeheavy weapons <> <> <> <> nothing <> <> <> <> 50
is <> it <> nothing <> relaxing;to walk in the woods <> <> <> nothing <> <> <> <> 50
lang_en/conceptnet-commonsense-is-1.pro view on Meta::CPAN
is <> e-mail <> a form <> of communication <> <> <> nothing <> <> <> <> 50
is is <> innovations <> nothing <> more common than <> <> <> nothing <> <> <> <> 50
is <> http <> a set <> of standards <> <> <> nothing <> <> <> <> 50
beings is <> human <> threatening the habitats <> of many other creatures <> <> <> nothing <> <> <> <> 50
is <> a ballad <> a long somg <> <> <> <> nothing <> <> <> <> 50
is streaming <> video <> nothing <> over the internet <> <> <> nothing <> <> <> <> 50
is <> the <> many species <> of insects <> <> <> nothing <> <> <> <> 50
is <> a bottle <> nothing <> on the table;standing <> <> <> nothing <> <> <> <> 50
is <> whales <> marine mammals <> <> <> <> nothing <> <> <> <> 50
is <> the statue <> a symbol <> of liberty;of freedom <> <> <> nothing <> <> <> <> 50
is <> a horse <> a mammal <> <> <> <> nothing <> <> <> <> 50
lang_en/conceptnet-commonsense-is-1.pro view on Meta::CPAN
is leaves modified <> flowers <> nothing <> <> <> <> nothing <> <> <> <> 50
is <> the violin <> a stringed instrument <> <> <> <> nothing <> <> <> <> 50
is running <> a person <> a shop <> <> <> <> nothing <> <> <> <> 50
is <> a author <> ending a story <> <> <> <> nothing <> <> <> <> 50
is <> a god <> ending a world <> <> <> <> nothing <> <> <> <> 50
is streaming <> a skateboard <> nothing <> down a sidewalk <> <> <> nothing <> <> <> <> 50
is <> pears <> fruits <> <> <> <> nothing <> <> <> <> 50
is <> champagne <> a alcoholic beverage <> <> <> <> nothing <> <> <> <> 50
is used <> rubber chickens <> nothing <> as jokes <> <> <> nothing <> <> <> <> 50
is <> bicycles <> complex machines <> <> <> <> nothing <> <> <> <> 50
is time <> measuring <> duration <> of events <> <> <> nothing <> <> <> <> 50
lang_en/conceptnet-commonsense-is-1.pro view on Meta::CPAN
is shoving <> he <> nothing <> a <> <> <> nothing <> <> <> <> 50
going is <> employees <> nothing <> to work <> <> <> nothing <> <> <> <> 50
coursing is <> dogs <> game <> <> <> <> nothing <> <> <> <> 50
crashing is <> a car <> a good hobby <> <> <> <> nothing <> <> <> <> 50
is <> a monkey wrench <> a good weapon <> <> <> <> nothing <> <> <> <> 50
is streaming tears <> nothing <> nothing <> down <> <> <> nothing <> <> <> <> 50
is <> a fitting room <> a place <> <> try <> before purchasing them <> nothing <> on clothes <> xxtoxx <> <> 50
is <> a discotheque <> a club <> <> recorded <> music <> nothing <> <> xxtoxx <> <> 50
is <> a index card <> a small piece <> of lightweight card <> <> <> nothing <> <> <> <> 50
is <> a car park <> a place cars <> to park <> <> <> nothing <> <> <> <> 50
is <> a projectile <> something <> <> <> <> nothing <> <> <> <> 50
lang_en/conceptnet-commonsense-is-1.pro view on Meta::CPAN
is <> a axe <> a way wood <> into smaller pieces;of breaking <> <> <> nothing <> <> <> <> 50
is <> a jug <> nothing <> a;container <> <> <> nothing <> <> <> <> 50
is <> creme dental <> pasta <> <> <> <> nothing <> <> <> <> 50
is <> music <> a language <> <> <> <> nothing <> <> <> <> 50
is time <> it <> cleaning <> again <> <> <> nothing <> <> <> <> 50
is streaming tears <> your eyes <> nothing <> <> <> <> nothing <> <> <> <> 50
is <> frisbees <> round <> <> <> <> nothing <> <> <> <> 50
called is <> the study <> astronomy <> of the sky <> <> <> nothing <> <> <> <> 50
called is <> planets <> astronomy <> of the sky <> <> <> nothing <> <> <> <> 50
is <> he <> having a ball <> <> <> <> nothing <> <> <> <> 50
is <> a cup <> put <> in a saucer <> <> <> nothing <> <> <> <> 50
view release on metacpan or search on metacpan
lib/Fsdb.pm view on Meta::CPAN
=cut
our $VERSION = '3.4';
=head1 SYNOPSIS
Fsdb, the flatfile streaming database is package of commands
for manipulating flat-ASCII databases from
shell scripts. Fsdb is useful to process medium amounts of data (with
very little data you'd do it by hand, with megabytes you might want a
real database).
Fsdb was known as as Jdb from 1991 to Oct. 2008.
lib/Fsdb.pm view on Meta::CPAN
=over 4
=item INCOMPATIBLE CHANGE
Jdb has been renamed Fsdb, the flatfile-streaming database.
This change affects all internal Perl APIs,
but no shell command-level APIs.
While Jdb served well for more than ten years,
it is easily confused with the Java debugger (even though Jdb was there first!).
It also is too generic to work well in web search engines.