view release on metacpan or search on metacpan
ext/xxHash/xxhash.h view on Meta::CPAN
XXH_PUBLIC_API XXH64_state_t* XXH64_createState(void);
XXH_PUBLIC_API XXH_errorcode XXH64_freeState(XXH64_state_t* statePtr);
/* hash streaming */
XXH_PUBLIC_API XXH_errorcode XXH32_reset (XXH32_state_t* statePtr, unsigned int seed);
XXH_PUBLIC_API XXH_errorcode XXH32_update (XXH32_state_t* statePtr, const void* input, size_t length);
XXH_PUBLIC_API XXH32_hash_t XXH32_digest (const XXH32_state_t* statePtr);
view release on metacpan or search on metacpan
lib/Directory/Scanner.pm view on Meta::CPAN
->ignore(sub { $_->basename =~ /^\./ })
->recurse;
=head1 DESCRIPTION
This module provides a streaming interface for traversing directories.
Unlike most modules that provide similar capabilities, this will not
pre-fetch the list of files or directories, but instead will only focus
on one thing at a time. This is useful if you have a large directory tree
and need to do a lot of resource intensive work on each file.
view release on metacpan or search on metacpan
0.045 2017-05-30 00:04:46Z
- fix MSWin32 test failures where path separators do not come out as
expected
0.044 2017-03-29 00:14:00Z
- once again streaming command output as each line is produced, rather than
buffering until the process ends (this behaviour was changed in 0.040)
0.043 2016-02-15 04:20:20Z
- new [Run::BeforeArchive] plugin
view release on metacpan or search on metacpan
share/specs/v1.25.yaml view on Meta::CPAN
description: |
Replay previous logs from the container.
This is useful for attaching to a container that has started and you want to output everything since the container started.
If `stream` is also enabled, once all the previous output has been returned, it will seamlessly transition into streaming current output.
type: "boolean"
default: false
- name: "stream"
in: "query"
description: "Stream attached streams from the the time the request was made onwards"
share/specs/v1.25.yaml view on Meta::CPAN
in: "query"
description: "Show events created since this timestamp then stream new events."
type: "string"
- name: "until"
in: "query"
description: "Show events created until this timestamp then stop streaming."
type: "string"
- name: "filters"
in: "query"
description: |
A JSON encoded value of filters (a `map[string][]string`) to process on the event list. Available filters:
view release on metacpan or search on metacpan
t/dracula.DOS.txt view on Meta::CPAN
whether she dies conscious or in her sleep. Wake that poor boy, and
let him come and see the last. He trusts us, and we have promised
him."
I went to the dining room and waked him. He was dazed for a moment,
but when he saw the sunlight streaming in through the edges of the
shutters he thought he was late, and expressed his fear. I assured
him that Lucy was still asleep, but told him as gently as I could that
both Van Helsing and I feared that the end was near. He covered his
face with his hands, and slid down on his knees by the sofa, where he
remained, perhaps a minute, with his head buried, praying, whilst his
t/dracula.DOS.txt view on Meta::CPAN
understand that sunrise and sunset are to her times of peculiar
freedom. When her old self can be manifest without any controlling
force subduing or restraining her, or inciting her to action. This
mood or condition begins some half hour or more before actual sunrise
or sunset, and lasts till either the sun is high, or whilst the clouds
are still aglow with the rays streaming above the horizon. At first
there is a sort of negative condition, as if some tie were loosened,
and then the absolute freedom quickly follows. When, however, the
freedom ceases the change back or relapse comes quickly, preceded
only by a spell of warning silence.
view release on metacpan or search on metacpan
lib/ETL/Yertl.pm view on Meta::CPAN
pipeline. If the size of the data is known, it can even provide
a progress bar and an ETA.
=item L<netcat (nc)|http://netcat.sourceforge.net>
Netcat allows simple streaming over a network. Using Netcat you can
start a Yertl pipeline on one machine and finish it on another machine.
For example, you could generate metrics on each client machine, and then
write them to a central machine to insert into a database on that
machine.
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
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);