view release on metacpan or search on metacpan
lib/Device/WebIO/Dancer.pm view on Meta::CPAN
my $mime_type = $type1 . '/' . $type2;
my $in_fh = $webio->vid_stream( $name, $channel, $mime_type );
return send_file( '/etc/hosts',
streaming => 1,
system_path => 1,
content_type => $mime_type,
callbacks => {
around_content => sub {
my ($writer, $chunk) = @_;
view release on metacpan or search on metacpan
- SPI interface
0.007 2014-11-30
- Video streaming
0.006 2014-11-22
- Use GStreamer to get image rather than calling raspistill
- Add quality parameter to examples/picture.pl
view release on metacpan or search on metacpan
$outsideTempHumIndex,
$outsideTempHumIndexMaximum,
$avgWindChill,
$windChillMinimum);
B<&getSensorImage> enables a continuous streaming of "live" weather
data from the Davis Wx Station. I've found this stream to be very
easy to get out of sync, so this funcion reads a single block, stops
the streaming, and flushes the serial receive buffer. The data
returned by this function are the current values and not average
values within a sample period, like &getArcImg returns. The array
returned is as follows:
@array = ($insideTemp,
}
return 1;
}
##
## `getSensorImage' enables a continuous streaming of 18 byte chunks of
## weather data from the Davis Wx Station. I've found this stream to be
## very easy to get out of sync, so this funcion read a single 18 byte chunk,
## stops the streaming, and flushes the serial Rx buffer
##
sub getSensorImage {
##### LOOP ######
# Monitor, Wizard, and Perception Sensor Image:
# start of block 1 byte
view release on metacpan or search on metacpan
highwayhash/c/highwayhash.h view on Meta::CPAN
HighwayHashState state;
uint8_t packet[32];
int num;
} HighwayHashCat;
/* Allocates new state for a new streaming hash computation */
void HighwayHashCatStart(const uint64_t key[4], HighwayHashCat* state);
void HighwayHashCatAppend(const uint8_t* bytes, size_t num,
HighwayHashCat* state);
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
dist_zilla_docker_api_plugin_plan.md view on Meta::CPAN
$client->remote_tag_exists($image_ref); # optional registry helper
```
### `...::Progress`
Docker build/push endpoints return streaming progress records. The plugin should parse these and forward:
```text
stream/status/progress -> log_debug or log
errorDetail/error -> log_fatal
aux.ID -> captured image ID
dist_zilla_docker_api_plugin_plan.md view on Meta::CPAN
sub build_image {
my ($self, %arg) = @_;
# Adapter maps normalized plugin args to API::Docker method calls.
# It must consume the full streaming response and return a Result object.
}
sub push_image {
my ($self, %arg) = @_;
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
eg/cancel_streaming.pl view on Meta::CPAN
#!/usr/bin/env perl
# Cancel a streaming select mid-flight from inside the on_data callback,
# once a condition is met. The connection stays alive for follow-up queries.
use strict;
use warnings;
use EV;
use EV::ClickHouse;
view release on metacpan or search on metacpan
eg/resumable_watch.pl view on Meta::CPAN
#!/usr/bin/env perl
#
# resumable_watch.pl - A watcher that survives process restarts without
# missing events. Persists the last seen revision to a file; on startup,
# reads it back, lists any keys changed during downtime via a one-shot
# get(prefix=>1, revision=>) and then resumes streaming from the next
# revision.
#
# Handles the compaction edge case: if the server has compacted past our
# saved revision, the watch arrives in the *error* callback (per the POD
# documentation of watch's error semantics). We then re-list at HEAD and
view release on metacpan or search on metacpan
lib/EV/MariaDB.pm view on Meta::CPAN
my ($rows, $err) = @_;
# callbacks fire in order
});
}
# streaming row-by-row (no full-result buffering)
$m->query_stream("select * from big_table", sub {
my ($row, $err) = @_;
if ($err) { warn $err; return }
if (!defined $row) { print "done\n"; return } # EOF
# process $row (arrayref)
lib/EV/MariaDB.pm view on Meta::CPAN
=item * Async transaction control (commit, rollback, autocommit)
=item * Connection utility operations (ping, reset, reset_connection,
change_user, select_db, set_charset)
=item * BLOB/TEXT streaming via C<send_long_data>
=item * Async graceful close via C<close_async>
=item * Multi-result set support for multi-statement queries
lib/EV/MariaDB.pm view on Meta::CPAN
=item utf8 => 1
When enabled, result strings from columns with a UTF-8 charset are
automatically flagged with Perl's internal UTF-8 flag (C<SvUTF8_on>).
Applies to text queries, prepared statements, and streaming results.
Without this option, all result values are returned as raw byte
strings (matching DBD::mysql's default).
Column names in C<$fields> are UTF-8-flagged when the connection
charset is C<utf8> or C<utf8mb4>, regardless of this option.
lib/EV/MariaDB.pm view on Meta::CPAN
=item * on error with C<(undef, $error_message)>
=back
Unlike C<query>, rows are not buffered -- suitable for very large
result sets. No other queries can be queued while streaming is active.
=head2 close_async
$m->close_async(sub { my ($ok, $err) = @_ });
lib/EV/MariaDB.pm view on Meta::CPAN
flag set so C<length>, regex, and other character operations behave
correctly.
=head2 Reading
With C<< utf8 => 1 >>, text query, prepared-statement, and streaming
results are UTF-8-flagged per column based on the column's charset.
Binary and non-UTF-8 columns are returned as raw bytes. Column names
in C<$fields> are UTF-8-flagged whenever the connection charset is
C<utf8> or C<utf8mb4>, regardless of this option.
view release on metacpan or search on metacpan
eg/copy_out.pl view on Meta::CPAN
use warnings;
use EV;
use EV::Pg;
# Demonstrates the multi-phase COPY OUT callback protocol:
# 1. callback fires with ("COPY_OUT") -- streaming has begun
# 2. caller drains rows by looping get_copy_data until it returns -1
# 3. callback fires AGAIN with ($cmd_tuples) on completion
my $conninfo = shift || $ENV{TEST_PG_CONNINFO} || 'dbname=postgres';
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