view release on metacpan or search on metacpan
lib/PSGI/Handy.pm view on Meta::CPAN
=head1 LIMITATIONS
The C<$app> returned by C<to_app> always produces the buffered,
three-element PSGI response C<[ $status, \@headers, \@body ]>. The PSGI
delayed-response form (the streaming "responder" callback) is not
generated; this is what "PSGI-subset" means throughout this distribution.
Concurrency and the HTTP version depend on the PSGI server you choose.
No multipart uploads or WebSocket in this version. C<HEAD> requests are
served by the matching C<GET> route with the body removed.
view release on metacpan or search on metacpan
share/dot-psgi/echo-stream.psgi view on Meta::CPAN
use AnyEvent;
my $app = sub {
my $env = shift;
warn "This app needs a server that supports psgi.streaming"
unless $env->{'psgi.streaming'};
my $cv = AE::cv;
return sub {
my $respond = shift;
my $w = $respond->([ 200, ['X-Foo' => 'bar', 'Content-Type' => 'text/plain'] ]);
view release on metacpan or search on metacpan
share/doc/wxwidgets.pod view on Meta::CPAN
virtual istream& LoadObject(istream& stream)
virtual wxInputStream& LoadObject(wxInputStream& stream)
Override this function and call it from your own LoadObject before
streaming your own data. LoadObject is called by the framework
automatically when the document contents need to be loaded.
Note that only one of these forms exists, depending on how wxWidgets
was configured.
share/doc/wxwidgets.pod view on Meta::CPAN
virtual ostream& SaveObject(ostream& stream)
virtual wxOutputStream& SaveObject(wxOutputStream& stream)
Override this function and call it from your own SaveObject before
streaming your own data. SaveObject is called by the framework
automatically when the document contents need to be saved.
Note that only one of these forms exists, depending on how wxWidgets
was configured.
share/doc/wxwidgets.pod view on Meta::CPAN
and then call wxMediaCtrl::Play to show the video/audio of the media
in that event.
More complex operations are generally more heavily dependant on the
capabilities of the backend. For example, QuickTime cannot set the
playback rate of certain streaming media - while DirectShow is
slightly more flexible in that regard.
=head2 Operation
When wxMediaCtrl plays a file, it plays until the stop position is
view release on metacpan or search on metacpan
lib/Padre/Task/Run.pm view on Meta::CPAN
package Padre::Task::Run;
# Generic task for executing programs via system() and streaming
# their output back to the main program.
use 5.008005;
use strict;
use warnings;
view release on metacpan or search on metacpan
root/static/yui/charts/charts-debug.js view on Meta::CPAN
}
return "";
}
};
/* fix for video streaming bug */
YAHOO.deconcept.SWFObjectUtil.cleanupSWFs = function()
{
var objects = document.getElementsByTagName("OBJECT");
for(var i = objects.length - 1; i >= 0; i--)
{
view release on metacpan or search on metacpan
lib/Parse/CSV.pm view on Meta::CPAN
This method is fine unless your CSV files start to get large. Once that
happens, the only existing option is to fall back on the relatively slow
and heavyweight L<XML::SAXDriver::CSV> module.
L<Parse::CSV> fills this functionality gap. It provides a flexible
and light-weight streaming parser for large, extremely large, or
arbitrarily large CSV files.
=head2 Main Features
B<Stream-Based Parser> - All parsing a line at a time.
view release on metacpan or search on metacpan
lib/Parse/DebControl.pm view on Meta::CPAN
=item * CHANGES file now generated automatically
=item * Fixes for potential test suite failure in Pod::Coverage run
=item * Adds the "addNewline" option to write_file to solve the streaming stanza problem.
=item * Adds tests for the addNewline option
=back
view release on metacpan or search on metacpan
lib/Parse/Gnaw/Blocks/ParsingMethods.pm view on Meta::CPAN
read in the entire stream (petabytes) into memory and crash the system.
if it doesn't crash, it will back up until it finds amatch.
We default to thrifty matching, meaning we only read in as little as possible
to still find a match. This means we only read in just as much of the
stream as we need to find a match.
We can DO greedy matching, but it can be a problem if we're streaming massive quantities of data.
basic thrifty algorithm:
try the rule at least min times.
if that matches, then return and let rest of grammar try.
If rest of grammar dies, then revert to min location
view release on metacpan or search on metacpan
lib/Parse/M3U/Extended.pm view on Meta::CPAN
=head1 SEE ALSO
=over
=item * IETF Internet Draft: draft-pantos-http-live-streaming-08
=back
=head1 COPYRIGHT
view release on metacpan or search on metacpan
examples/7.0.3/asup01.txt view on Meta::CPAN
Sat Mar 17 21:00:00 PDT [oren-netapp: kern.uptime.filer:info]: 9:00pm up 963 days, 9:06 204327914692 NFS ops, 0 CIFS ops, 694 HTTP ops, 0 DAFS ops, 0 FCP ops, 0 iSCSI ops
Sat Mar 17 22:00:00 PDT [oren-netapp: kern.uptime.filer:info]: 10:00pm up 963 days, 10:06 204340168883 NFS ops, 0 CIFS ops, 694 HTTP ops, 0 DAFS ops, 0 FCP ops, 0 iSCSI ops
Sat Mar 17 23:00:00 PDT [oren-netapp: kern.uptime.filer:info]: 11:00pm up 963 days, 11:06 204344688894 NFS ops, 0 CIFS ops, 694 HTTP ops, 0 DAFS ops, 0 FCP ops, 0 iSCSI ops
Sun Mar 18 00:00:00 PDT [oren-netapp: kern.uptime.filer:info]: 12:00am up 963 days, 12:06 204348443008 NFS ops, 0 CIFS ops, 694 HTTP ops, 0 DAFS ops, 0 FCP ops, 0 iSCSI ops
<perf-info><object-info><objectname>system</objectname><counters><counter-info><name>nfs_ops</name><desc>NFS operations per second</desc><privilege-level>basic</privilege-level><properties>rate</properties><unit>per_sec</unit></counter-info><counter-...
view release on metacpan or search on metacpan
0.202 2023-11-27 07:23:21-05:00 America/New_York
0.106 2016-08-07 19:19:46-04:00 America/New_York
Adding an is_smallbiz() function to check for small business.
Adding a script to demonstrate streaming use of data
0.105 2016-08-07 17:04:51-04:00 America/New_York
Fixing documentation error. Adding an example script
view release on metacpan or search on metacpan
lib/Parse/WBXML.pm view on Meta::CPAN
the other modules in L</SEE ALSO> first. The current API may change before the 1.0
release.
Provides a pure-Perl implementation for the WBXML compressed XML format.
Slower and less efficient than the libwbxml2-based alternatives (L</SEE ALSO>),
but supports streaming SAX-like parsing.
This may be of some use in low-bandwidth situations where you want data as soon
as available from the stream, or in cases where the document is damaged and you
want to recover as much data as possible, or if you just don't have libwbxml2
available.
view release on metacpan or search on metacpan
lib/Paws/AppStream.pm view on Meta::CPAN
Amazon AppStream 2.0
This is the I<Amazon AppStream 2.0 API Reference>. This documentation
provides descriptions and syntax for each of the actions and data types
in AppStream 2.0. AppStream 2.0 is a fully managed, secure application
streaming service that lets you stream desktop applications to users
without rewriting applications. AppStream 2.0 manages the AWS resources
that are required to host and run your applications, scales
automatically, and provides access to your users on demand.
You can call the AppStream 2.0 API operations by using an interface VPC
lib/Paws/AppStream.pm view on Meta::CPAN
Each argument is described in detail in: L<Paws::AppStream::CreateFleet>
Returns: a L<Paws::AppStream::CreateFleetResult> instance
Creates a fleet. A fleet consists of streaming instances that run a
specified image.
=head2 CreateImageBuilder
lib/Paws/AppStream.pm view on Meta::CPAN
Each argument is described in detail in: L<Paws::AppStream::CreateImageBuilderStreamingURL>
Returns: a L<Paws::AppStream::CreateImageBuilderStreamingURLResult> instance
Creates a URL to start an image builder streaming session.
=head2 CreateStack
=over
lib/Paws/AppStream.pm view on Meta::CPAN
Each argument is described in detail in: L<Paws::AppStream::CreateStack>
Returns: a L<Paws::AppStream::CreateStackResult> instance
Creates a stack to start streaming applications to users. A stack
consists of an associated fleet, user access policies, and storage
configurations.
=head2 CreateStreamingURL
lib/Paws/AppStream.pm view on Meta::CPAN
Each argument is described in detail in: L<Paws::AppStream::CreateStreamingURL>
Returns: a L<Paws::AppStream::CreateStreamingURLResult> instance
Creates a temporary URL to start an AppStream 2.0 streaming session for
the specified user. A streaming URL enables application streaming to be
tested without user setup.
=head2 CreateUpdatedImage
lib/Paws/AppStream.pm view on Meta::CPAN
Each argument is described in detail in: L<Paws::AppStream::DeleteDirectoryConfig>
Returns: a L<Paws::AppStream::DeleteDirectoryConfigResult> instance
Deletes the specified Directory Config object from AppStream 2.0. This
object includes the information required to join streaming instances to
an Active Directory domain.
=head2 DeleteFleet
lib/Paws/AppStream.pm view on Meta::CPAN
Each argument is described in detail in: L<Paws::AppStream::DeleteStack>
Returns: a L<Paws::AppStream::DeleteStackResult> instance
Deletes the specified stack. After the stack is deleted, the
application streaming environment provided by the stack is no longer
available to users. Also, any reservations made for application
streaming sessions for the stack are released.
=head2 DeleteUsageReportSubscription
lib/Paws/AppStream.pm view on Meta::CPAN
Each argument is described in detail in: L<Paws::AppStream::DescribeSessions>
Returns: a L<Paws::AppStream::DescribeSessionsResult> instance
Retrieves a list that describes the streaming sessions for a specified
stack and fleet. If a UserId is provided for the stack and fleet, only
streaming sessions for that user are described. If an authentication
type is not provided, the default is to authenticate users using a
streaming URL.
=head2 DescribeStacks
=over
lib/Paws/AppStream.pm view on Meta::CPAN
Each argument is described in detail in: L<Paws::AppStream::ExpireSession>
Returns: a L<Paws::AppStream::ExpireSessionResult> instance
Immediately stops the specified streaming session.
=head2 ListAssociatedFleets
=over
view release on metacpan or search on metacpan
lib/PawsX/S3/Uploader.pm view on Meta::CPAN
use Carp ();
class PawsX::S3::Uploader;
our $VERSION = '0.0.3'; # VERSION
# ABSTRACT: upload to S3 from a streaming source
# aws doesn't want small multiparts
sub MULTIPART_MIN_SIZE { 5*1024*1024 }
lib/PawsX/S3/Uploader.pm view on Meta::CPAN
=encoding UTF-8
=head1 NAME
PawsX::S3::Uploader - upload to S3 from a streaming source
=head1 VERSION
version 0.0.3
view release on metacpan or search on metacpan
lib/PawsX/Waiter/waiters.json view on Meta::CPAN
{"mediaconnect":{"2018-11-14":{"FlowActive":{"description":"Wait until a flow is active","acceptors":[{"state":"success","expected":"ACTIVE","matcher":"path","argument":"Flow.Status"},{"state":"retry","expected":"STARTING","matcher":"path","argument"...
view release on metacpan or search on metacpan
lib/Plack/Middleware/PeriAHS/Respond.pm view on Meta::CPAN
sub call {
log_trace("=> PeriAHS::Respond middleware");
my ($self, $env) = @_;
die "This middleware needs psgi.streaming support"
unless $env->{'psgi.streaming'};
my $rreq = $env->{"riap.request"};
my $pa = $env->{"periahs.riap_client"}
or die "\$env->{'periahs.riap_client'} not defined, ".
"perhaps ParseRequest middleware has not run?";
view release on metacpan or search on metacpan
Perinci::Result::Format. There are now Perinci-CmdLine and
Perinci-CmdLine-Lite distributions.
- Refactoring: run() and run_*() now returns enveloped response instead
of int. All output is now returned as string by run_*() instead of
printed directly (except for streaming output).
- Refactoring: No long uses internal attributes like
$self->{_subcommand}. Instead, now a per-request (per-run())
stash/hash $r is passed around. This is not unlike the technique used
in Apache handlers and Data::Sah. It's cleaner because the
display_result() (should not be a problem because it's not yet
documented).
[ENHANCEMENTS]
- Support streaming output (function needs to set result metadata
is_stream => 1 and result needs to be glob/IO::Handle/array/tied
array, format needs to be text).
- Observe 'x.perinci.cmdline.default_format' metadata attribute.
view release on metacpan or search on metacpan
lib/Perinci/CmdLine/Inline.pm view on Meta::CPAN
my @modules_for_all_args;
my @req_stmts;
for my $arg (sort keys %$args_prop) {
my $arg_spec = $args_prop->{$arg};
# we don't validate streaming input for now
next if $arg_spec->{stream};
my $arg_schema = $arg_spec->{schema};
my $arg_term = '$args->{"'.$arg.'"}';
if (defined $arg_spec->{default}) {
lib/Perinci/CmdLine/Inline.pm view on Meta::CPAN
$shebang_line = $args{shebang} // $^X;
$shebang_line = "#!$shebang_line" unless $shebang_line =~ /\A#!/;
$shebang_line .= "\n" unless $shebang_line =~ /\R\z/;
}
# this will be removed if we don't use streaming input or read from
# stdin
$cd->{sub_srcs}{_pci_gen_iter} = <<'_';
require Data::Sah::Util::Type;
my ($fh, $type, $argname) = @_;
if (Data::Sah::Util::Type::is_simple($type)) {
view release on metacpan or search on metacpan
lib/Perinci/CmdLine/Base.pm view on Meta::CPAN
#log_trace("TMP: handle cmdline_src for arg=%s", $an);
my $as = $args_p->{$an};
my $src = $as->{cmdline_src};
my $type = $as->{schema}[0]
or die "BUG: No schema is defined for arg '$an'";
# Riap::HTTP currently does not support streaming input
my $do_stream = $as->{stream} && $url !~ /^https?:/;
if ($src) {
die [531,
"Invalid 'cmdline_src' value for argument '$an': $src"]
unless $src =~ /\A(stdin|file|stdin_or_files?|stdin_or_args|stdin_line)\z/;
lib/Perinci/CmdLine/Base.pm view on Meta::CPAN
All direct subclasses of PC:Base do the formatting here.
=head2 $cmd->hook_display_result($r)
The hook is supposed to display the formatted result (stored in C<$r->{fres}>)
to STDOUT. But in the case of streaming output, this hook can also set it up.
All direct subclasses of PC:Base do the formatting here.
=head2 $cmd->hook_after_run($r)
lib/Perinci/CmdLine/Base.pm view on Meta::CPAN
and then skip saving output.
Data that is not representable as JSON will be cleansed using
L<Data::Clean::ForJSON>.
Streaming output will not be saved appropriately, because streaming output
contains coderef that will be called repeatedly during the normal displaying of
result.
=head2 PERINCI_CMDLINE_PLUGINS
view release on metacpan or search on metacpan
1.811.0 2018-03-17 Released-By: PERLANCAR
- Synchronize version with latest Perinci::CmdLine::Lite.
- [doc] Add FAQ section "Progress Indicator", add example for streaming
a file in output, add list of tutorial pages to fill in later.
1.77 2017-07-31 Released-By: PERLANCAR
view release on metacpan or search on metacpan
script/peri-eg-read-file view on Meta::CPAN
[--format-options=s] [--format=name] [--json] [--(no)naked-res]
[--no-config] [--no-env] <path>
=head1 DESCRIPTION
This function demonstrate output streaming of bytes.
To do output streaming, on the function side, you just return a coderef which
can be called by caller (e.g. CLI framework L<Perinci::CmdLine>) to read data
from. Code must return data or undef to signify exhaustion.
This works over remote (HTTP) too, because output streaming is supported by
L<Riap::HTTP> (version 1.2) and L<Perinci::Access::HTTP::Client>. Streams
are translated into HTTP chunks.
=head1 OPTIONS
view release on metacpan or search on metacpan
script/peri-eg-read-file-lite view on Meta::CPAN
[--(no)naked-res] [--no-config | -C] [--no-env]
[--page-result[=program]] <path>
=head1 DESCRIPTION
This function demonstrate output streaming of bytes.
To do output streaming, on the function side, you just return a coderef which
can be called by caller (e.g. CLI framework L<Perinci::CmdLine>) to read data
from. Code must return data or undef to signify exhaustion.
This works over remote (HTTP) too, because output streaming is supported by
L<Riap::HTTP> (version 1.2) and L<Perinci::Access::HTTP::Client>. Streams
are translated into HTTP chunks.
=head1 OPTIONS
view release on metacpan or search on metacpan
lib/Perinci/Examples/FilePartial.pm view on Meta::CPAN
The functions are separated into this module because these functions read/write
files on the filesystem and might potentially be dangerous if
`Perinci::Examples` is exposed to the network by accident.
See also `Perinci::Examples::FileStream` which uses streaming instead of
partial.
_
};
lib/Perinci/Examples/FilePartial.pm view on Meta::CPAN
The functions are separated into this module because these functions read/write
files on the filesystem and might potentially be dangerous if
C<Perinci::Examples> is exposed to the network by accident.
See also C<Perinci::Examples::FileStream> which uses streaming instead of
partial.
=head1 FUNCTIONS
view release on metacpan or search on metacpan
lib/Perinci/Sub/Wrapper.pm view on Meta::CPAN
"my \$err_$dn;",
"$cd->{result};",
);
if ($argspec->{stream}) {
$self->push_lines(
'if ('."\$err_$dn".') { die "Record #$i of streaming argument '."'$prefix$argname'".' ($rec) fails validation: '."\$err_$dn".'" }',
'$rec;',
);
} else {
$self->_errif(
400, qq["Argument '$prefix$argname' fails validation: \$err_$dn"],
view release on metacpan or search on metacpan
t/corpus-stack/HTTP-Handy/lib/HTTP/Handy.pm view on Meta::CPAN
psgi.version (PSGI requires [1,1]; not set)
psgi.multithread (not set; effectively false)
psgi.multiprocess (not set; effectively false)
psgi.run_once (not set; effectively false)
psgi.nonblocking (not set; always blocking)
psgi.streaming (not set; not supported)
Applications that check for these keys must treat their absence as false.
For full PSGI/1.1 compliance use L<Plack> (requires Perl 5.8+).
=head1 SECURITY
t/corpus-stack/HTTP-Handy/lib/HTTP/Handy.pm view on Meta::CPAN
=item * No HTTPS (see above)
=item * No chunked transfer encoding
=item * No streaming -- POST body and response body are fully buffered in memory
=item * Maximum POST body size: 10 MB by default (configurable via C<max_post_size>)
=item * No cookie or session management (implement in the application layer)
view release on metacpan or search on metacpan
lib/PerlPoint/Generator.pm view on Meta::CPAN
[
"acceptedFormat=s@", # more accepted formats (embedded or included);
"activeContents", # evaluation of active contents;
"cache", # control the cache;
"cacheCleanup", # cache cleanup;
"dstreaming|docstreaming=s", # document stream handling (allow "docstreaming" for backwards compatibility);
"help", # online help, usage;
"imagedir|image_dir=s", # target image directory (allow "image_dir" for backwards compatibility with pp2html);
"imageref|image_ref=s", # target image directory reference (allow "image_ref" for backwards compatibility with pp2html);
"includelib=s@", # library pathes;
"nocopyright", # suppress copyright message;
lib/PerlPoint/Generator.pm view on Meta::CPAN
Cleans up the cache. Mostly invoked automatically. See docs for details.
EOO
dstreaming => <<EOO,
Document stream handling (for backwards compatibility, C<-docstreaming> can still be used).
Takes a numerical flag value as argument.
Example: -dstreaming 2
By default (or when 0 is passed as value), document streams are evaluated as streams. A value
of 1 ignores all docstreams, while a value of 2 treats docstream entry points as headlines.
For details about document streams please see the parser documentation and the tutorial.
lib/PerlPoint/Generator.pm view on Meta::CPAN
Example: -skipstream details
Note: you cannot skip the "main" stream.
Note: to skip document streams I<in general>, use C<-dstreaming 1>.
EOO
streamBuffer => <<EOO,
lib/PerlPoint/Generator.pm view on Meta::CPAN
skipcomments => exists $me->{options}{skipcomments},
docstreams2skip => exists $me->{options}{skipstream} ? $me->{options}{skipstream} : [],
docstreaming => (exists $me->{options}{dstreaming} and ($me->{options}{dstreaming}==DSTREAM_HEADLINES or $me->{options}{dstreaming}==DSTREAM_IGNORE)) ? $me->{options}{dstreaming} : DSTREAM_DEFAULT,
nestedTables => $me->{build}{nestedTables},
vispro => 1,
view release on metacpan or search on metacpan
lib/Perlbal/Plugin/PSGI.pm view on Meta::CPAN
'psgi.url_scheme' => 'http',
'psgi.nonblocking' => Plack::Util::TRUE,
'psgi.run_once' => Plack::Util::FALSE,
'psgi.multithread' => Plack::Util::FALSE,
'psgi.multiprocess' => Plack::Util::FALSE,
'psgi.streaming' => Plack::Util::TRUE,
REMOTE_ADDR => $pb->{peer_ip},
SERVER_NAME => $server_name,
SERVER_PORT => $server_port,
};
view release on metacpan or search on metacpan
lib/Perlbal/Plugin/FlvStreaming.pm view on Meta::CPAN
=head1 NAME
Perlbal::Plugin::FlvStreaming - Enable FLV streaming with reverse proxy
=head1 DESCRIPTION
This plugin enable FLV streaming by modifying headers and prepending
FLV header to the body.
=head1 SYNOPSIS
LOAD FlvStreaming
lib/Perlbal/Plugin/FlvStreaming.pm view on Meta::CPAN
sub load { }
sub register {
my ($class, $svc) = @_;
unless ($svc && $svc->{role} eq "reverse_proxy") {
die "You can't load the flvstreaming plugin on a service not of role reverse_proxy.\n";
}
$svc->register_hook('FlvStreaming', 'start_proxy_request', \&start_proxy_request);
$svc->register_hook('FlvStreaming', 'modify_response_headers', \&modify_response_headers);
$svc->register_hook('FlvStreaming', 'prepend_body', \&prepend_body);
view release on metacpan or search on metacpan
lib/Perlito5X/Test2/API.pm view on Meta::CPAN
$hub->format(undef) if $hide;
}
}
elsif (! $parent->format) {
# If our parent has no format that means we're in a buffered subtest
# and now we're trying to run a streaming subtest. There's really no
# way for that to work, so we need to force the use of a buffered
# subtest here as
# well. https://github.com/Test-More/test-more/issues/721
$buffered = 1;
}
view release on metacpan or search on metacpan
t/01-basics.t view on Meta::CPAN
ok( my $oid = $o->pgblobs_create_blob() , "Blob is created");
ok( $oid = $o->pgblobs_store_blob('BINARYCONTENT') , "Something is stored in blob");
ok( my $rc = $o->pgblobs_fetch_blob($oid) , "Fetched content");
ok( $rc eq 'BINARYCONTENT' , "Same content was retrieved");
{
## A bit of cake streaming now
my $nslices = 1000;
my $cake;
my $read = sub{
unless( $nslices-- ){ return undef ;}
my $slice = int(rand(1000)) + 1 ;