view release on metacpan or search on metacpan
lib/Wallflower.pm view on Meta::CPAN
SERVER_NAME => $self->url->host,
SERVER_PORT => $self->url->port,
SERVER_PROTOCOL => "HTTP/1.0",
# wallflower defaults
'psgi.streaming' => 1,
};
# add If-Modified-Since headers if the target file exists
my $target = $self->target($uri);
$env->{HTTP_IF_MODIFIED_SINCE} = time2str( ( stat _ )[9] ) if -e $target;
lib/Wallflower.pm view on Meta::CPAN
my $response = shift;
# delayed response
( $status, $headers, $content ) = @$response;
# streaming
if ( !defined $content ) {
return bless {}, 'Wallflower::NULL'
if $status ne '200'; # we don't care about the body
return _build_handle( $file = $target );
}
view release on metacpan or search on metacpan
- No Changes since last trial
0.001060 2018-03-13 11:11:27-07:00 America/Los_Angeles (TRIAL RELEASE)
- Fix parsing of streaming subtests
0.001059 2018-03-12 13:26:43-07:00 America/Los_Angeles
- Job id's are now uuid's. Numbers for humans are now names
- Use UUIDs for event IDs
view release on metacpan or search on metacpan
lib/App/column/run.pm view on Meta::CPAN
our %SPEC;
# TODO: color theme
# TODO: parallel execution
# TODO: streaming/immediate output
$SPEC{column_run} = {
v => 1.1,
summary => 'Run several commands and show their output in multiple columns',
description => <<'_',
lib/App/column/run.pm view on Meta::CPAN
except with the following differences:
* commands are run in sequence, not in parallel (although parallel execution is
a TODO list item);
* all output are collected first, then displayed (although streaming output is a
TODO list item);
* multiplexing STDIN to all commands;
* ANSI color and wide character handling;
lib/App/column/run.pm view on Meta::CPAN
=over
=item * commands are run in sequence, not in parallel (although parallel execution is
a TODO list item);
=item * all output are collected first, then displayed (although streaming output is a
TODO list item);
=item * multiplexing STDIN to all commands;
=item * ANSI color and wide character handling;
view release on metacpan or search on metacpan
script/contenttype view on Meta::CPAN
application/x-spss-sav zsav
application/x-sql sql
application/x-ssdl+xml ssdl
application/x-step step
application/x-step stp
application/x-streamingmedia ssm
application/x-stuffit sit
application/x-stuffit sitx
application/x-subrip srt
application/x-sv4cpio sv4cpio
application/x-sv4crc sv4crc
view release on metacpan or search on metacpan
t/data/build.single_extended.log view on Meta::CPAN
t/aggregate/live_component_controller_action_local.t .................. ok
t/aggregate/live_component_controller_action_multipath.t .............. ok
t/aggregate/live_component_controller_action_path.t ................... ok
t/aggregate/live_component_controller_action_path_matchsingle.t ....... ok
t/aggregate/live_component_controller_action_private.t ................ ok
t/aggregate/live_component_controller_action_streaming.t .............. ok
t/aggregate/live_component_controller_action_visit.t .................. ok
t/aggregate/live_component_controller_actionroles.t ................... ok
t/aggregate/live_component_controller_anon.t .......................... ok
t/aggregate/live_component_controller_args.t .......................... ok
t/aggregate/live_component_controller_attributes.t .................... ok
view release on metacpan or search on metacpan
lib/Perinci/CmdLine/dux.pm view on Meta::CPAN
# set `out` argument for the dux function
my $streamo = $r->{meta}{"x.app.dux.is_stream_output"} //
$r->{meta}{"x.dux.is_stream_output"}; # backward-compat, will be removed someday
my $fmt = $r->{format} // 'text';
if (!defined($streamo)) {
# turn on streaming if format is simple text
my $iactive;
if (-t STDOUT) {
$iactive = 1;
} elsif ($ENV{INTERACTIVE}) {
$iactive = 1;
lib/Perinci/CmdLine/dux.pm view on Meta::CPAN
}
sub hook_format_result {
my ($self, $r) = @_;
# turn off streaming if response is an error response
if ($r->{res}[0] !~ /\A2/) {
$r->{is_stream_output} = 0;
}
return '' if $r->{is_stream_output};
view release on metacpan or search on metacpan
script/freqtable view on Meta::CPAN
1 two
1 four
=head2 Running table (`--output-every` option)
If you have streaming input, you can instruct `freqtable` to print the result
periodically after a number of input lines/words/characters/bytes. You can also
instruct to clear the terminal screen before every output
(`--clear-before-output`).
% perl -MArray::Sample::WeightedRandom=sample_weighted_random_with_replacement \
view release on metacpan or search on metacpan
- Adjust to App::wordlist 0.270 (option 'random' re-added).
0.005 2020-05-18 Released-By: PERLANCAR; Urgency: medium
- Update to App::wordlist 0.268+ (streaming result).
0.004 2018-01-09 Released-By: PERLANCAR
- Update to App::genpw 0.002.
view release on metacpan or search on metacpan
lib/FlashVideo/RTMPDownloader.pm view on Meta::CPAN
my($r_fh, $w_fh); # So Perl doesn't close them behind our back..
if ($rtmp_data->{live} && $self->action eq 'play') {
# Playing live stream, we pipe this straight to the player, rather than
# saving on disk.
# XXX: The use of /dev/fd could go away now rtmpdump supports streaming to
# STDOUT.
pipe($r_fh, $w_fh);
my $pid = fork;
view release on metacpan or search on metacpan
lib/App/htmlcat.pm view on Meta::CPAN
my $self = shift;
return sub {
my $env = shift;
$env->{'psgi.streaming'} or die 'psgi.streaming not supported';
if ($env->{PATH_INFO} eq '/stream') {
return sub {
my $respond = shift;
view release on metacpan or search on metacpan
lib/App/karr/Foundation.pm view on Meta::CPAN
my $log_file = $repo->child('.karr.log');
# Native pipe: the child writes stdout+stderr, the parent reads. The parent
# is the tee — it fans each chunk to the persistent log, the terminal (when
# streaming), and an in-memory buffer for error scanning. No external tee
# process to race, and the run's output is captured directly (no re-slurping
# the log via byte offsets).
pipe( my $reader, my $writer ) or croak "pipe failed: $!";
my $pid = fork;
view release on metacpan or search on metacpan
lib/App/Phoebe/Chat.pm view on Meta::CPAN
encode_utf8
"This server supports a Gemini-based chat. "
. "If you don't have a dedicated client, you can use two windows of a regular Gemini client. "
. "Visit the following two URLs. "
. "The first one allows you “listen†to the channel and the second one allows you to “say†things. "
. "The connection to the “listen†channel needs a streaming client. "
. "Use a client certificate with the same common name for both connections.\n");
$stream->write("=> $url/listen\r\n");
$stream->write("=> $url/say\r\n");
}
view release on metacpan or search on metacpan
You can run rmcd on one computer and remotely control it on another,
fully transparent. It only cares for the presence of the named pipe.
You can also setup mplayer to stream the content to you, creating a
solution similar to MPD and their builti-in httpd streaming (except MPD
does not support video streaming).
rmcd features a built-in, user configurable, web radio management
system, functionality for copying the current track to your portable mp3
player or wherever you prefer, favorizing of tracks and loading of the
same, now playing information for both local files and streams, along
view release on metacpan or search on metacpan
0.006 2023-02-12 Released-By: PERLANCAR; Urgency: medium
- Add action 'stream_as_csv'
- Handle table with infinite rows by streaming as CSV as default action.
0.005 2022-10-18 Released-By: PERLANCAR; Urgency: low
- No functional changes.
view release on metacpan or search on metacpan
- Fix lookup of "Property:P_"
0.3.2 2015-10-16 14:14:24 CEST
- Fix zero-result-bug in lookup mode
- Support limit in lookup mode
- Enable streaming output of simple JSON format
0.3.1 2015-10-16 11:13:18 CEST
- Simplify lookup by passing ids as command line arguments
- Implement proper exit codes and option to ignore errors
view release on metacpan or search on metacpan
lib/App/wordlist/blossom.pm view on Meta::CPAN
=item * B<random> => I<bool>
Pick random words.
If set to true, then streaming will be turned off. All words will be gathered
first, then words will be chosen randomly from the gathered list.
=item * B<wordlist_bundles> => I<array[str]>
Select one or more wordlist bundle (Acme::CPANModules::WordListBundle::*) modules.
view release on metacpan or search on metacpan
lib/App/wordlist/wordle.pm view on Meta::CPAN
=item * B<random> => I<bool>
Pick random words.
If set to true, then streaming will be turned off. All words will be gathered
first, then words will be chosen randomly from the gathered list.
=item * B<wordlist_bundles> => I<array[str]>
Select one or more wordlist bundle (Acme::CPANModules::WordListBundle::*) modules.
view release on metacpan or search on metacpan
lib/App/wordlist.pm view on Meta::CPAN
},
random => {
summary => 'Pick random words',
description => <<'_',
If set to true, then streaming will be turned off. All words will be gathered
first, then words will be chosen randomly from the gathered list.
_
schema => 'bool*',
cmdline_aliases => {r=>{}},
lib/App/wordlist.pm view on Meta::CPAN
=item * B<random> => I<bool>
Pick random words.
If set to true, then streaming will be turned off. All words will be gathered
first, then words will be chosen randomly from the gathered list.
=item * B<wordlist_bundles> => I<array[str]>
Select one or more wordlist bundle (Acme::CPANModules::WordListBundle::*) modules.
view release on metacpan or search on metacpan
Tue Apr 30 14:19:52 2024 +0100
882745aa42cff181597a451a8f137d095703cbfb
4.004 30 April 2024
* #20 weak encryption + streaming does not set local CRC value to zero
Tue Apr 30 10:41:48 2024 +0100
7952c1c46282ebd54f80736cd3da659c0d430f3e
* typo - 0027 test directory should be 0027-bsdtar
Tue Apr 30 10:18:15 2024 +0100
view release on metacpan or search on metacpan
unzip-6.0/unzip.c view on Meta::CPAN
" Currently split archives are not readable by unzip. A workaround is",
" to use zip to convert the split archive to a single-file archive and",
" use unzip on that. See the manual page for Zip 3.0 or later.",
"",
"Streaming (piping into unzip):",
" Currently unzip does not support streaming. The funzip utility can be",
" used to process the first entry in a stream.",
" cat archive | funzip",
"",
"Testing archives:",
" -t test contents of archive",
view release on metacpan or search on metacpan
lib/Archive/Zip/SimpleUnzip.pm view on Meta::CPAN
*$inner->{NewStream} = 0 ;
*$inner->{EndStream} = 0 ;
*$inner->{TotalInflatedBytesRead} = 0;
*$inner->{Info}{TrailerLength} = 0;
# disable streaming if present & set sizes from central dir
# TODO - this will only allow a single file to be read at a time.
# police it or fix it.
*$inner->{ZipData}{Streaming} = 0;
*$inner->{ZipData}{Crc32} = $member->{CRC32};
*$inner->{ZipData}{CompressedLen} = $member->{CompressedLength};
lib/Archive/Zip/SimpleUnzip.pm view on Meta::CPAN
'LocalHeaderOffset' => $locHeaderOffset,
'CompressedLength' => $compressedLength ,
'UncompressedLength' => $uncompressedLength ,
'CRC32' => $crc32 ,
#'Time' => _dosToUnixTime($lastModTime),
#'Stream' => $streamingMode,
#'Zip64' => $zip64,
#
#'MethodID' => $compressedMethod,
);
push @CD, \%data;
view release on metacpan or search on metacpan
t/18_bug_92205.t view on Meta::CPAN
# Archive::Zip was blowing up when processing member
# 'Configurations2/accelerator/current.xml' from the LibreOffice file.
#
# 'current.xml' is a zero length file that has been compressed AND uses
# streaming. That means the uncompressed length is zero but the compressed
# length is greater than 0.
#
# The fix for issue #101092 added code that forced both the uncompressed &
# compressed lengths to be zero if either was zero. That caused this issue.
# This set of test checks that a zero length zip member will ALWAYS be
# mapped to a zero length stored member, regardless of the compression
# method used or the use of streaming.
#
# Input files all contain a single zero length member.
# Streaming & Compression Method are set as follows.
#
# File Streamed Method
view release on metacpan or search on metacpan
lib/Ark/Context.pm view on Meta::CPAN
and $self->dispatch_auto_action
and $match->dispatch($self);
$self->detached(0);
$self->dispatch_private_action('end')
unless $self->res->is_deferred or $self->res->is_streaming;
}
else {
$self->log( error => 'no action found' );
}
}
view release on metacpan or search on metacpan
lib/ArrayData/Lingua/Word/EN/Enable.pm view on Meta::CPAN
mainsprings
mainstay
mainstays
mainstream
mainstreamed
mainstreaming
mainstreams
maintain
maintainabilities
maintainability
maintainable
lib/ArrayData/Lingua/Word/EN/Enable.pm view on Meta::CPAN
slipslops
slipsole
slipsoles
slipstream
slipstreamed
slipstreaming
slipstreams
slipt
slipup
slipups
slipware
lib/ArrayData/Lingua/Word/EN/Enable.pm view on Meta::CPAN
streamed
streamer
streamers
streamier
streamiest
streaming
streamings
streamlet
streamlets
streamline
streamlined
streamliner
view release on metacpan or search on metacpan
lib/ArrayData/Lingua/Word/EN/Medical/Glutanimate.pm view on Meta::CPAN
straw
strawberry
streak
streaks
stream
streaming
streams
streblomicrodactyly
Strecker
street
Streeter
view release on metacpan or search on metacpan
lib/ArrayData/Word/EN/Enable.pm view on Meta::CPAN
mainsprings
mainstay
mainstays
mainstream
mainstreamed
mainstreaming
mainstreams
maintain
maintainabilities
maintainability
maintainable
lib/ArrayData/Word/EN/Enable.pm view on Meta::CPAN
slipslops
slipsole
slipsoles
slipstream
slipstreamed
slipstreaming
slipstreams
slipt
slipup
slipups
slipware
lib/ArrayData/Word/EN/Enable.pm view on Meta::CPAN
streamed
streamer
streamers
streamier
streamiest
streaming
streamings
streamlet
streamlets
streamline
streamlined
streamliner
view release on metacpan or search on metacpan
lib/Arriba/Server.pm view on Meta::CPAN
SCRIPT_NAME => '',
'psgi.version' => [ 1, 1 ],
'psgi.errors' => *STDERR,
'psgi.url_scheme' => $req->{scheme},
'psgi.nonblocking' => Plack::Util::FALSE,
'psgi.streaming' => Plack::Util::TRUE,
'psgi.run_once' => Plack::Util::FALSE,
'psgi.multithread' => Plack::Util::FALSE,
'psgi.multiprocess' => Plack::Util::TRUE,
'psgix.io' => $client,
'psgix.input.buffered' => Plack::Util::TRUE,
view release on metacpan or search on metacpan
docs/api/ExtractText.md view on Meta::CPAN
```
PUT http://api.aspose.cloud/v4.0/cells/content/extract/text
```
### **Function Description**
Extracts substrings, numbers, or fixed-length prefixes/suffixes from the selected range and writes the results directly to the target area—no Excel formulas, no helper columns, no manual copy-paste.The engine works cell-by-cell:- **String cells** a...
### The request parameters of **extractText** API are:
| Parameter Name | Type | Path/Query String/HTTPBody | Description |
| :- | :- | :- |:- |
view release on metacpan or search on metacpan
lib/At/Protocol/Firehose.pm view on Meta::CPAN
$fh->start();
=head1 DESCRIPTION
C<At::Protocol::Firehose> handles the real-time streaming of events from an AT Protocol relay or PDS. It decodes the
binary DAG-CBOR messages into Perl data structures using L<Codec::CBOR>.
Each message from the firehose consists of two parts:
=over
view release on metacpan or search on metacpan
lib/Atomic/Pipe.pm view on Meta::CPAN
The kernel pipe buffer size (see L</resize>) does B<not> affect this --
fragmentation is keyed on the POSIX C<PIPE_BUF> atomic-write threshold, not on
the buffer capacity.
=head3 Benchmark: streaming JSON objects
Numbers below are from C<bench/zstd_compression.pl> in the distribution. The
workload is a synthetic but representative stream of JSON log/event objects
sent in mixed-data mode via C<write_message>. The corpus is generated once and
reused across all runs; sizes are JSON-encoded byte counts.