view release on metacpan or search on metacpan
lib/Data/Password/Top10000.pm view on Meta::CPAN
treble
tralala
tigercat
tarakan
sunlight
streaming
starr
sonysony
smart1
skylark
sites
view release on metacpan or search on metacpan
lib/Data/Password/zxcvbn/RankedDictionaries/French.pm view on Meta::CPAN
'strates' => 14939,
'stratford' => 23964,
'stratification' => 24585,
'stratos' => 28468,
'stream' => 27544,
'streaming' => 20258,
'street' => 2976,
'stress' => 6952,
'strict' => 7454,
'stricte' => 6666,
'strictement' => 4370,
view release on metacpan or search on metacpan
lib/Data/Password/zxcvbn/RankedDictionaries/English.pm view on Meta::CPAN
'streaked' => 19793,
'streaks' => 12060,
'stream' => 2228,
'streamed' => 11794,
'streamer' => 27344,
'streaming' => 6219,
'streamline' => 14870,
'streamlined' => 10083,
'streamlining' => 21663,
'streams' => 3638,
'streatham' => 21689,
view release on metacpan or search on metacpan
lib/Data/Random/Contact/Language/EN.pm view on Meta::CPAN
mainstay's
mainstays
mainstream
mainstream's
mainstreamed
mainstreaming
mainstreams
maintain
maintainability
maintainable
maintained
lib/Data/Random/Contact/Language/EN.pm view on Meta::CPAN
stream's
streamed
streamer
streamer's
streamers
streaming
streaming's
streamline
streamline's
streamlined
streamlines
streamlining
lib/Data/Random/Contact/Language/EN.pm view on Meta::CPAN
upstarting
upstarts
upstate
upstream
upstreamed
upstreaming
upstreams
upsurge
upsurged
upsurges
upsurging
view release on metacpan or search on metacpan
lib/Data/Random/dict view on Meta::CPAN
streaks
stream
streamed
streamer
streamers
streaming
streamline
streamlined
streamliner
streamlines
streamlining
view release on metacpan or search on metacpan
lib/Data/Riak/Fast/MapReduce.pm view on Meta::CPAN
=head1 METHOD
=head2 mapreduce
Execute the mapreduce query.
To enable streaming, do the following:
my $results = $mr->mapreduce(chunked => 1);
=cut
view release on metacpan or search on metacpan
lib/Data/Riak/MapReduce.pm view on Meta::CPAN
=head2 mapreduce
Execute the mapreduce query.
To enable streaming, do the following:
my $results = $mr->mapreduce(chunked => 1);
=head1 AUTHORS
view release on metacpan or search on metacpan
lib/Data/TOON.pm view on Meta::CPAN
=over 4
=item * Encoding is O(n) in data size
=item * Decoding is O(n) in text size
=item * Memory usage is proportional to data complexity
=item * Large documents (>100MB) may require streaming parser
=back
=head1 SECURITY
view release on metacpan or search on metacpan
lib/Data/Unixish.pm view on Meta::CPAN
from the returned filehandle. (Currently not yet supported on Windows due to no
support for open '-|').
The C<*duxl> functions returns result as list. It can be evaluated in scalar to
return only the first element of the list. However, the whole list will be
calculated first. Use C<*duxf> for streaming interface.
=head2 cduxa($func, $icallback) => ARRAYREF
=head2 cduxc($func, $icallback, $ocallback)
view release on metacpan or search on metacpan
examples/roundtrip.pl view on Meta::CPAN
@$_
)
})
->completed;
$log->infof('Copy data in');
# Normally you'd have a proper source that's streaming from some other system,
# this construct looks a bit unwieldy on its own but the ->from method
# would also accept the arrayref-of-rows directly.
await $db->query('copy roundtrip_one(name) from stdin')
->from([ map [ $_ ], qw(first second third) ])
->completed;
view release on metacpan or search on metacpan
lib/Database/Async/Query.pm view on Meta::CPAN
sub in {
my ($self) = @_;
$self->{in} //= do {
my $sink = $self->db->new_sink;
die 'already have streaming input but no original ->{in} sink' if $self->{streaming_input};
$sink->source->completed->on_ready(sub { $log->debugf('Sink for %s completed with %s', $self, shift->state) });
$self->{streaming_input} = $sink->source->buffer->pause;
$self->ready_to_stream->on_done(sub {
$log->debugf('Ready to stream, resuming streaming input');
$self->streaming_input->resume;
});
$sink
}
}
#sub {
# my ($self) = @_;
# my $engine = $self->{engine} or die 'needs a valid ::Engine instance';
# my $sink = $self->in or die 'had no valid sink for streaming input';
#
# my $src = $sink->buffer;
# $src->pause;
# $engine->stream_from($src);
#
lib/Database/Async/Query.pm view on Meta::CPAN
# })->on_cancel(sub {
# $src->completed->cancel unless $sink->completed->is_ready;
# });
#}
sub streaming_input { shift->{streaming_input} // die '->in has not yet been called' }
sub finish {
my ($self) = @_;
if($self->{in}) {
$self->input_stream->done;
view release on metacpan or search on metacpan
lib/Devel/Agent.pm view on Meta::CPAN
default=>0,
);
=item * on_frame_end=>CodeRef
This code ref is called when a frame is closed. This should act as the default data streaming hook callback. All tracing operations are halted durriong this callback.
Example:
sub {
my ($self,$last)=@_;
view release on metacpan or search on metacpan
0.01 2012-09-29 Tim Bunce
* Created new Devel::Memory extension using a modified version of
Devel::Size's perl memory data crawler, extended to support
callbacks, a 'data path name' concept, data streaming,
data processing and visualization.
* The Devel::Memory core was based on 0.77. The generic changes
will be fed back to Devel::Size so it will remain the
canonical source of knowledge of how to crawl perl internals.
view release on metacpan or search on metacpan
lib/Devel/hdb/App/Assets.pm view on Meta::CPAN
$fh->binmode();
} else {
$type = 'text/plain';
}
if ($env->{'psgi.streaming'}) {
return [ 200, ['Content-Type' => $type], $fh];
} else {
local $/;
my $buffer = <$fh>;
return [ 200, ['Content-Type' => $type], [$buffer]];
view release on metacpan or search on metacpan
integration/blank-env/run-integration.pl view on Meta::CPAN
stderr => defined $stderr ? $stderr : '',
};
}
# _capture_stream_prefix($label, $command, %opts)
# Runs one streaming shell command and records when expected stdout chunks first appear.
# Input: human label, shell command string, expected_chunks array ref, and optional timeout seconds.
# Output: hash reference with stdout, stderr, and matched event timing data.
sub _capture_stream_prefix {
my ( $label, $command, %opts ) = @_;
my $expected = $opts{expected_chunks} || [];
view release on metacpan or search on metacpan
lib/Device/SaleaeLogic.pm view on Meta::CPAN
sub is_usb2 {
return saleaeinterface_is_usb2($_[0]->{obj}, $_[1]);
}
sub is_streaming {
return saleaeinterface_is_streaming($_[0]->{obj}, $_[1]);
}
sub get_channel_count {
return saleaeinterface_get_channel_count($_[0]->{obj}, $_[1]);
}
lib/Device/SaleaeLogic.pm view on Meta::CPAN
This method can be invoked from any callback provided to the C<new()> function
or from outside the callbacks as long as you have a copy of the
Device::SaleaeLogic object created by C<new()> and a copy of the C<$id> as well.
=item C<is_streaming($id)>
This method informs the user whether the device with ID C<$id> is streaming data
or not. This is useful to know before calling methods like C<read_start()>,
C<write_start()> and C<stop()>. It returns 1 if streaming is going on and 0
otherwise.
The way to invoke this method is as below:
if ($self->is_streaming($id)) {
# ... do something ...
# ... look at the section for read_start() for an example ...
}
This method can be invoked from any callback provided to the C<new()> function
lib/Device/SaleaeLogic.pm view on Meta::CPAN
=item C<read_start($id)>
This method starts the data sampling from the Logic or Logic16 device given by
the ID C<$id>. This should be called only once and to check for whether to call
it or not the user should use C<is_streaming($id)> before that.
The way to invoke this method is as below:
unless ($self->is_streaming($id)) {
$self->read_start($id);
}
This method should B<not> be invoked from any callback provided to the C<new()>
function. It has to be invoked from outside of the callbacks as shown in
F<share/example.pl> in the distribution.
=item C<stop($id)>
This method stops the data streaming that is currently happening for the Logic
or Logic16 device given by the device ID C<$id>. This should be called after
checking with C<is_streaming($id)>.
The way to invoke this method is as below:
if ($self->is_streaming($id)) {
$self->stop($id);
}
This method can be invoked from any callback provided to the C<new()> function
or from outside the callbacks as long as you have a copy of the
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
lib/Device/WebIO.pm view on Meta::CPAN
=head3 vid_stream
vid_stream( $name, $channel, $type );
Returns a filehandle for streaming the video channel. C<$type> is one of the
MIME types returned by C<vid_allowed_content_types()>.
=head2 Video Callback
These can be used if the device does the C<VideoOutputCallback> role.
lib/Device/WebIO.pm view on Meta::CPAN
=head3 img_stream
img_stream( $name, $channel, $type );
Returns a filehandle for streaming the video channel. C<$type> is one of the
MIME types return by C<img_allowed_content_types()>.
=head2 I2C
=head3 i2c_read
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
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/EV/ClickHouse.pm view on Meta::CPAN
=item C<query_timeout> — per-query timeout in seconds, overriding the
connection-level C<query_timeout>.
=item C<on_data> — native protocol only. A code ref called for each data
block as it arrives. Enables streaming: rows are delivered incrementally
and not accumulated.
$ch->query("SELECT * FROM big_table",
{ on_data => sub { my ($rows) = @_; process_batch($rows) } },
sub { my (undef, $err) = @_; ... } # final callback
view release on metacpan or search on metacpan
lib/EV/Etcd.pm view on Meta::CPAN
RPC timeout in seconds. Default is 30 seconds. Minimum value is 1 second.
=item max_retries
Maximum number of reconnection attempts for streaming operations (watch,
lease_keepalive, election_observe) after a connection failure. Default is 3.
Set to 0 to disable automatic reconnection.
=item health_interval
lib/EV/Etcd.pm view on Meta::CPAN
=head2 lease_keepalive
my $keepalive = $client->lease_keepalive($lease_id, $callback);
my $keepalive = $client->lease_keepalive($lease_id, \%opts, $callback);
Keep a lease alive. Creates a bidirectional streaming connection that keeps
the lease refreshed. Returns an C<EV::Etcd::Keepalive> object that can be
used to cancel the keepalive stream:
$keepalive->cancel(sub { my ($resp, $err) = @_; });
lib/EV/Etcd.pm view on Meta::CPAN
=head2 election_observe
my $observe = $client->election_observe($name, $callback);
my $observe = $client->election_observe($name, \%opts, $callback);
Observe leader changes for an election. This creates a streaming connection
that receives notifications whenever the leader changes. Returns an
C<EV::Etcd::Observe> object that can be used to cancel the observe stream:
$observe->cancel(sub { my ($resp, $err) = @_; });
view release on metacpan or search on metacpan
lib/EV/MariaDB.pm view on Meta::CPAN
=item * Async transaction control (commit, rollback, autocommit)
=item * Connection utility operations (ping, reset, 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>).
This applies to text queries, prepared statements, and streaming results.
Column names in C<$fields> are UTF-8-flagged when the connection charset
is C<utf8> or C<utf8mb4>, regardless of this option. Without this option,
all result values are returned as raw byte
strings (the default, matching DBD::mysql behavior).
lib/EV/MariaDB.pm view on Meta::CPAN
per row with C<($arrayref)>, once at EOF with C<(undef)>, or on error
with C<(undef, $error_message)>. Unlike C<query>, results are not
buffered in memory - suitable for large result sets.
This is an exclusive operation: 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
set, so C<length()>, regex, and other character operations work correctly.
=head2 Reading data
With C<< utf8 => 1 >>, text query results, prepared statement results, and
streaming results are automatically UTF-8-flagged per column based on the
column's charset. Binary and non-UTF-8 columns are returned as raw byte
strings. Column names (the C<$fields> arrayref) are UTF-8-flagged when the
connection charset is C<utf8> or C<utf8mb4>, regardless of this option.
Without C<< utf8 => 1 >>, all result values are byte strings (the default).