Result:
found more than 672 distributions - search limited to the first 2001 files matching your query
( run in 0.475 )
AnyEvent-RabbitMQ
view release on metacpan or search on metacpan
share/fixed_amqp0-8.xml view on Meta::CPAN
<!--
======================================================
== STREAMING
======================================================
-->
work with streaming content
<doc>
The stream class provides methods that support multimedia streaming.
The stream class uses the following semantics: one message is one
packet of data; delivery is unacknowleged and unreliable; the consumer
can specify quality of service parameters that the server can try to
adhere to; lower-priority messages may be discarded in favour of high
priority messages.
share/fixed_amqp0-8.xml view on Meta::CPAN
<field name = "consume rate" type = "long">
transfer rate in octets/second
<doc>
Specifies a desired transfer rate in octets per second. This is
usually determined by the application that uses the streaming
data. A value of zero means "no limit", i.e. as rapidly as
possible.
</doc>
<doc name = "rule">
The server MAY ignore the prefetch values and consume rates,
share/fixed_amqp0-8.xml view on Meta::CPAN
the queue was declared as private, and ideally, impose no limit
except as defined by available resources.
</doc>
<doc name = "rule">
Streaming applications SHOULD use different channels to select
different streaming resolutions. AMQP makes no provision for
filtering and/or transforming streams except on the basis of
priority-based selective delivery of individual messages.
</doc>
<chassis name = "server" implement = "MUST" />
<response name = "consume-ok" />
AnyEvent-Twitter-Stream
view release on metacpan or search on metacpan
lib/AnyEvent/Twitter/Stream.pm view on Meta::CPAN
=for test_synopsis
my($user, $password, @following_ids, $consumer_key, $consumer_secret, $token, $token_secret);
=head1 NAME
AnyEvent::Twitter::Stream - Receive Twitter streaming API in an event loop
=head1 SYNOPSIS
use AnyEvent::Twitter::Stream;
lib/AnyEvent/Twitter/Stream.pm view on Meta::CPAN
$done->recv;
=head1 DESCRIPTION
AnyEvent::Twitter::Stream is an AnyEvent user to receive Twitter streaming
API, available at L<http://dev.twitter.com/pages/streaming_api> and
L<http://dev.twitter.com/pages/user_streams>.
See L<eg/track.pl> for more client code example.
=head1 METHODS
AnyEvent-WebSocket-Server
view release on metacpan or search on metacpan
t/testlib/PSGI.pm view on Meta::CPAN
my ($ws_server) = @_;
return sub {
my ($env) = @_;
return sub {
my $responder = shift;
note("server enters streaming callback");
$cv_server_finish->begin;
$ws_server->establish_psgi($env)->cb(sub {
my $cv = shift;
my ($conn, $validate_str) = try { $cv->recv };
if(!$conn) {
Apache-Dynagzip
view release on metacpan or search on metacpan
Dynagzip.pm view on Meta::CPAN
user's connection.
At the time we decided to go for dynamic compression there were no
appropriate software on the market. Even later in
February 2002 Nicholas Oxhøj wrote to the mod_perl mailing list about his
experience of finding Apache gzipper for the streaming outgoing content:
=for html
<blockquote>
I<"... I have been experimenting with all the different Apache compression modules
Dynagzip.pm view on Meta::CPAN
I<... Wouldn't it be nice to have some option to specify that the handler should flush
and send the currently compressed output every time it had received a certain amount
of input or every time it had generated a certain amount of output?..>
I<... So I am basically looking for anyone who has had any success in achieving this
kind of "streaming" compression, who could direct me at an appropriate Apache module.">
=for html
</blockquote>
Unfortunately for him, C<Apache::Dynagzip> has not yet been publicly available at that time...
Apache-LogFormat-Compiler
view release on metacpan or search on metacpan
t/Req2PSGI.pm view on Meta::CPAN
'psgi.input' => $input,
'psgi.errors' => *STDERR,
'psgi.multithread' => $FALSE,
'psgi.multiprocess' => $FALSE,
'psgi.run_once' => $TRUE,
'psgi.streaming' => $TRUE,
'psgi.nonblocking' => $FALSE,
@_,
};
for my $field ( $req->headers->header_field_names ) {
Apache-MP3-Skin
view release on metacpan or search on metacpan
(string) JavaScript to add the selected MP3S to the playlist.
=item ALLOW_DOWNLOAD
(1|0) Is streaming allowed? Set by PerlSetVar AllowDownload. It's good form to test
if streaming is allowed before using variables like FETCH_URL which will not work.
=item ALLOW_STREAM
(1|0) Is streaming allowed? Set by PerlSetVar AllowStream. It's good form to test
if streaming is allowed before using variables like PLAY_URL which will not work.
=item BASE_DIR
(string) path the base directory. Set by PerlSetVar BaseDir and defaulted to
/apache_mp3.
=item STREAM_TIMEOUT
(int) If anything but 0, this returns the number in seconds of how long a file
will stream before timing out, otherwise returns an empty string. Set by
PerlSetVar StreamTimeout. Used for demos or in cases when streaming an entire
song would not be appropriate or illegal.
=item UNSELECT_ALL_MP3S_SCRIPT
(string) JavaScript that Unchecks all the checkboxes generated by
Apache-MP3
view release on metacpan or search on metacpan
b("C"). $self->x("= Stream all songs"),
b("D"). $self->x("= Go to earlier directory"),
b("E"). $self->x("= Stream contents"),
b("F"). $self->x("= Enter directory"),
b("G"). $self->x("= Stream this song"),
b("H"). $self->x("= Select for streaming"),
b("I"). $self->x("= Download this song"),
b("J"). $self->x("= Stream this song"),
b("K"). $self->x("= Sort by field"),
);
}
return FORBIDDEN;
}
if ($self->check_stream_client and !$self->is_stream_client) {
my $useragent = $r->headers_in->{'User-Agent'};
$r->log_reason("CheckStreamClient is true and $useragent is not a streaming client");
return FORBIDDEN;
}
my $mime = $r->content_type;
my $file = $r->filename;
if (my $t = $self->stream_timeout) {
print p(strong(
$self->x('Note:')
),' ',
$self->x("In this demo, streaming is limited to approximately [quant,_1,second,seconds].", $t),
"\n"
);
}
print end_td;
sub download_ok {
my $d = shift->r->dir_config('AllowDownload') || '';
return $d !~ /$NO/oi;
}
# return true if streaming is allowed from this directory
sub stream_ok {
my $d = shift->r->dir_config('AllowStream') || '';
return $d !~ /$NO/oi;
}
sub playlocal_ok {
my $d = shift->r->dir_config('AllowPlayLocally') || '';
return $d =~ /$YES/oi;
}
# return true if we should check that the client can accomodate streaming
sub check_stream_client {
my $d = shift->r->dir_config('CheckStreamClient') || '';
return $d =~ /$YES/oi;
}
AddType application/x-ogg ogg OGG
AddType audio/wav wav WAV
Note that you need extemely large amounts of bandwidth to stream Wav
files, and that few audio file players currently support this type of
streaming. Wav file support is primarily intended to allow for
convenient downloads.
=item 3. Install icons and stylesheet
This module uses a set of icons and a cascading stylesheet to generate
users the same. The default is "no".
=item CheckStreamClient I<yes|no>
Setting CheckStreamClient to "yes" enables code that checks whether
the client claims to be able to accept streaming MPEG data. This
check isn't foolproof, but supports at least the most popular MP3
decoders (WinAmp, RealPlayer, xmms, mpg123). It also makes it harder
for users to download songs by pretending to be a streaming player.
The default is "no".
=item ReadMP3Info I<yes|no>
set to the physical filename of the MP3 file.
=item StreamTimeout I<integer>
For demo mode, you can specify a stream timeout in seconds.
Apache::MP3 will cease streaming the file after the time specified.
Because this feature uses the average bitrate of the song, it may be
off by a second or two when streaming variable bitrate MP3s.
=back
=head2 Configuration Variables Affecting Paths and Directories
Note: I prepared this image on an airplane, so it isn't as clean as I
would like. Volunteers to make a better help page are welcomed!
=item StreamBase I<URL>
A URL to use as the base for streaming. The default is to use the
same host for both directory listings and streaming. This may be of
use when running behind a firewall and the web server can't figure out
the correct address for the playlist automatically.
Example:
=item DescriptionFormat I<string>
The "Description" field, which is used both in the Description column
of the directory index and in the metadata sent to the player during
streaming, has a default format of I<title>-I<artist>-I<album>. The
description is constructed in such a way that the hyphen is omitted if
the corresponding field of the song's MP3 tag is empty.
You can customize this behavior by providing a I<DescriptionFormat>
string. These strings combine constant characters with %x format
<a href="/Songs/Madonna/like_a_virgin.mp3">Like a Virgin</a>
=item Stream an MP3 file
Replace the MP3 file's extension with .m3u and add the query string
"play=1". Apache::MP3 will generate a playlist for the streaming MP3
decoder to load. Example:
<a href="/Songs/Madonna/like_a_virgin.m3u?play=1">
Like a streaming Virgin</a>
=item Stream a directory
Append "/playlist.m3u?Play+All=1" to the end of the directory name:
Returns true if downloading files is allowed.
=item $boolean = $mp3->stream_ok
Returns true if streaming files is allowed.
=item $boolean = $mp3->check_stream_client
Returns true if the module should check the browser/MP3 player for
whether it accepts streaming.
=item $boolean = $mp3->is_stream_client
Returns true if this MP3 player can accept streaming. Note that this
is not a foolproof method because it checks a variety of
non-standardized headers and user agent names!
=item $boolean = $mp3->read_mp3_info
Returns true if the module should read MP3 info (true by default).
=item $seconds = $mp3->stream_timeout
Returns the number of seconds after which streaming should time out.
Used for "demo mode".
=item $lines = $mp3->file_list_is_long
Returns the number of lines in the MP3 file listing after which the
Apache-SdnFw
view release on metacpan or search on metacpan
lib/Apache/SdnFw/js/tinymce/examples/media/sample.ram view on Meta::CPAN
http://streaming.uga.edu/samples/ayp_lan.rm
Apache2-ModXml2
view release on metacpan or search on metacpan
lib/Apache2/ModXml2.pm view on Meta::CPAN
=head2 XPATH FILTERING
mod_xml2 implements functions for a filter that builds a DOM subtree
each time
a streaming xpath expression (named pattern by libxml2) matches.
The tree is passed passed to a callback function and decomposed
into single nodes again afterwards.
The streaming xpath expressions are from a very limited xpath subset
as described here:
http://www.w3.org/TR/xmlschema-1/#Selector
=over 1
=item xpath_filter_init
xpath_filter_init($f, $xpath, $namespaces, &transform);
To create a streaming xpath filter this function needs to be called
from filter init. The return value is suitable for returning it from
filter init.
Every time $xpath matches &transform is called with the subtrees root
node as a parameter. The namespaces needed to compile the pattern
Apache2-REST
view release on metacpan or search on metacpan
lib/Apache2/REST/Handler/stream.pm view on Meta::CPAN
:common :http
);
=head2 NAME
Apache2::REST::Handler::stream - test handler access '/test/stream' to test a streaming response
=cut
=head2 GET
Sets the response as a streaming one and returns OK on get.
=cut
sub GET{
my ($self, $req , $resp ) = @_ ;
if ( $req->param('die') ){
die "This is an error\n" ;
}
$resp->data()->{'test_mess'} = 'This is a GET test message on a streaming ressource' ;
$resp->stream(Apache2::REST::Stream::TestStream->new($req->param('chunks') || 10));
## It is OK
return Apache2::Const::HTTP_OK ;
}
App-CamelPKI
view release on metacpan or search on metacpan
lib/App/CamelPKI/CADB.pm view on Meta::CPAN
L</App::CamelPKI::CADB::_Schema::Certificate>.
Rationale for this 'slurpy' behavior: SQLite does not appreciate to have
a statement in progress when you close the connection (symptom:
C<cannot commit transaction - SQL statements in progress(1)>). That's
why we cannot use the "streaming" mode of DBIx::Class without a complex
system of statement caching in one time, I'm just too lazy to implement
right now...
=cut
App-DocKnot
view release on metacpan or search on metacpan
t/data/generate/remctl/docknot.yaml view on Meta::CPAN
suite.
Now, you can run the test suite with:
suffix: |
On particularly slow or loaded systems, you may see intermittent failures
from the `server/streaming` test because it's timing-sensitive.
The test suite will also need to be able to bind to 127.0.0.1 on port
11119 and 14373 to run test network server programs.
To test anonymous authentication, the KDC configured in the test suite
App-EventStreamr
view release on metacpan or search on metacpan
0.5 2015-08-02 21:02:32+08:00 Australia/Perth
Bug Fix - Crash on boot with missing ALSA device #54
Add YouTube Streaming Capability #80
0.4 2015-04-14 16:54:52+08:00 Australia/Perth
Bug fix - Missing 'MixerWait' for streaming process
0.3 2015-03-25 20:00:41WST+0800 Australia/Perth
Add IceCast Streaming Capability
App-HTTP_Proxy_IMP
view release on metacpan or search on metacpan
lib/App/HTTP_Proxy_IMP/IMP.pm view on Meta::CPAN
} else {
push @$ibuf, [ $offset,'' ];
}
last;
} elsif ( $ib0->[2] < 0 ) {
# streaming type:
# forward part of buf
push @$fwd, [
0, # not changed
substr($ib0->[1],0,$pass,''), # data
$ib0->[3], # callback
lib/App/HTTP_Proxy_IMP/IMP.pm view on Meta::CPAN
}
$DEBUG && $self->{request}->xdebug(
"can pass($dir) all: pass($canpass)>=data.len($dlen)");
return $callback->($self,$encoded_data // $data,0,$args);
} elsif ( $type < 0 ) {
# can pass part of data, only for streaming types
# remove from data what can be passed
die "body might change" if $self->{pass_encoded}[$dir];
$ibuf->[0][0] += $canpass;
my $passed_data = substr($data,0,$canpass,'');
$eobuf += $canpass;
lib/App/HTTP_Proxy_IMP/IMP.pm view on Meta::CPAN
$callback->($self,$encoded_data // $data,0,$args); # callback but continue
$DEBUG && $self->{request}->xdebug(
"can prepass($dir) all: pass($canprepass)>=data.len($dlen)");
goto SEND2IMP;
} elsif ( $type < 0 ) {
# can prepass part of data, only for streaming types
# remove from data what can be prepassed
die "body might change" if $self->{pass_encoded}[$dir];
$ibuf->[0][0] += $canprepass;
my $passed_data = substr($data,0,$canprepass,'');
$eobuf += $canprepass;
lib/App/HTTP_Proxy_IMP/IMP.pm view on Meta::CPAN
$ibuf->[-1] = [ $offset||$eobuf,$data,$type,$callback,$args ];
} elsif ( $type < 0
and $type == $ibuf->[-1][2]
and $callback == $ibuf->[-1][3]
) {
# streaming data, concatinate to existing buf of same type
$ibuf->[-1][1] .= $data;
} else {
# different type or non-streaming data, add new buf
push @$ibuf,[ $offset||$eobuf,$data,$type,$callback,$args ];
}
$DEBUG && $self->{request}->xdebug( "ibuf.length=%d",
$ibuf->[-1][0] + length($ibuf->[-1][1]) - $ibuf->[0][0]);
App-MHFS
view release on metacpan or search on metacpan
share/public_html/static/hls.js view on Meta::CPAN
* @param {ID3 frame} frame
*/
ID3.isTimeStampFrame = function isTimeStampFrame(frame) {
return frame && frame.key === 'PRIV' && frame.info === 'com.apple.streaming.transportStreamTimestamp';
};
ID3._getFrameData = function _getFrameData(data) {
/*
Frame ID $xx xx xx xx (four characters)
share/public_html/static/hls.js view on Meta::CPAN
break;
case 'DISCONTINUITY-SEQ':
cc = parseInt(value1);
break;
case 'KEY':
// https://tools.ietf.org/html/draft-pantos-http-live-streaming-08#section-3.4.4
var decryptparams = value1;
var keyAttrs = new attr_list(decryptparams);
var decryptmethod = keyAttrs.enumeratedString('METHOD'),
decrypturi = keyAttrs.URI,
decryptiv = keyAttrs.hexadecimalInteger('IV');
App-Phoebe
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");
}
App-PigLatin
view release on metacpan or search on metacpan
t/files/moby11.txt view on Meta::CPAN
and like to some flag-staff rising from the painted hull of an argosy,
the tall but shattered pole of a recent lance projected from the white
whale's back; and at intervals one of the cloud of soft-toed
fowls hovering, and to and fro skimming like a canopy over the fish,
silently perched and rocked on this pole, the long tail feathers
streaming like pennons.
A gentle joyousness--a mighty mildness of repose in swiftness,
invested the gliding whale. Not the white bull Jupiter swimming
away with ravished Europa clinging to his graceful horns;
his lovely, leering eyes sideways intent upon the maid;
t/files/moby11.txt view on Meta::CPAN
and spinning, animate and inanimate, all round and round in one vortex,
carried the smallest chip of the Pequod out of sight.
But as the last whelmings intermixingly poured themselves over
the sunken head of the Indian at the mainmast, leaving a few inches
of the erect spar yet visible, together with long streaming yards
of the flag, which calmly undulated, with ironical coincidings,
over the destroying billows they almost touched;--at that instant, a red
arm and a hammer hovered backwardly uplifted in the open air, in the act
of nailing the flag faster and yet faster to the subsiding spar.
A sky-hawk that tauntingly had followed the main-truck downwards
App-SeismicUnixGui
view release on metacpan or search on metacpan
lib/App/SeismicUnixGui/sunix/data/segyread.pm view on Meta::CPAN
tape is accessed with fread. We suggest that you try buff=1
even with EXABYTE tapes.
Caveat: may be slow on an 8mm streaming (EXABYTE) tapedrive
Warning: segyread or segywrite to 8mm tape is fragile. Allow sufficient
time between successive reads and writes.
App-SocialCalc-Multiplayer
view release on metacpan or search on metacpan
socialcalc/third-party/lib/PocketIO.pm view on Meta::CPAN
All the transports are supported.
WebSocket
Adobe(R) Flash(R) Socket
AJAX long polling
AJAX multipart streaming
Forever Iframe
JSONP Polling
=head2 TLS/SSL
App-Tailor
view release on metacpan or search on metacpan
lib/App/Tailor.pm view on Meta::CPAN
$ tail /var/log/some-log-file | my-filter.pl
=head1 DESCRIPTION
There are a number of programs available to filter, colorize, and modify
streaming output. Generating exactly the desired output often requires
pipe-chaining many calls to grep, cut, cols, jq, et al, or using an inflexible
config file or files, often in tandem with a long chain of piped commands.
C<App::Tailor> makes it easier to do this by making it trivial to write quick
scripts to filter, alter, and colorize output exactly as needed.
App-Tel
view release on metacpan or search on metacpan
local/lib/perl5/YAML/Tiny.pm view on Meta::CPAN
The YAML Tiny specification does not mandate any particular methodology
or mechanism for parsing.
Any compliant parser is only required to parse a single document at a
time. The ability to support streaming documents is optional and most
likely non-typical.
=for stopwords acyclic
Because anchors and aliases are not supported, the resulting representation
App-Wallflower
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 );
}
App-column-run
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;
App-contenttype
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
App-cpanminus-reporter
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
App-dux
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};
App-genpw-wordlist
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.
App-get_flash_videos
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;
App-htmlcat
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;
( run in 0.475 second using v1.01-cache-2.11-cpan-a5abf4f5562 )