view release on metacpan or search on metacpan
lib/Gzip/RandomAccess.pm view on Meta::CPAN
=head1 DESCRIPTION
This module allows you to randomly access a gzip deflate stream
as if it were a regular file, even though gzip is not designed
to be random-access. This is achieved by streaming the gzip file
in advance, building an index mapping compressed byte offsets to
uncompressed offsets, and at each point storing the 32KB of data
gzip needs to prime its decompression engine from that point.
The mechanism is taken from zran.c, an example in the zlib
view release on metacpan or search on metacpan
t/testpages/cnn.html view on Meta::CPAN
</TD><TD WIDTH="10"></TD><TD WIDTH="225">
<FONT FACE="helvetica, arial, sans-serif" SIZE="2">
<UL>
<li><a href="/WEATHER/9901/28/weather.page.pm.ap/">Cold and snowy across northern U.S.; rain elsewhere</a>
<LI><A HREF="/WEATHER/">Forecasts for 7,200 cities</A>
<LI><A HREF="/WEATHER/video/">Watch CNN's forecasts in streaming video</A>
</UL>
</FONT>
</TD></TR>
</TABLE>
view release on metacpan or search on metacpan
lib/HTML/HTML5/Parser/TagSoupParser.pm view on Meta::CPAN
$self->{line}++;
$self->{column} = 0;
} elsif ($self->{nc} == 0x000D) { # CR
## TODO: support for abort/streaming
my $next = '';
if ($input->read ($next, 1) and $next ne "\x0A") {
$self->{next_nc} = $next;
}
$self->{nc} = 0x000A; # LF # MUST
lib/HTML/HTML5/Parser/TagSoupParser.pm view on Meta::CPAN
if ($self->{nc} == 0x000A) { # LF
$p->{line}++;
$p->{column} = 0;
} elsif ($self->{nc} == 0x000D) { # CR
## TODO: support for abort/streaming
my $next = '';
if ($input->read ($next, 1) and $next ne "\x0A") {
$self->{next_nc} = $next;
}
$self->{nc} = 0x000A; # LF # MUST
view release on metacpan or search on metacpan
- removed dependency on HTML::Entities by hardcoding all relevant
entities. (HTML::Entities does a 'require HTML::Parser' which made the
parser=>0 feature break.)
- 0.09
- added Print feature to new() to allow Run() to return highlighted text
instead of automatically printing in a streaming fashion. Set Print=>0
to turn off print().
- Run() now returns highlighted text if Print=>0.
- changed parser=>0 to Parser=>0.
- the ParsedWords bug reported in 0.08 was really with my example in
get_snippet(). so rather than blame someone else's code, I fixed mine...
view release on metacpan or search on metacpan
iteration in succession using identical markup. You do this by creating a
<loop> tag in your template file containing the markup to be repeated, and
by creating a correspondingly named Loop object attached to the HTML::Macro
and containing all the data to be interpolated. Note: this requires all
data to be fetched and stored before it is applied to the template; there
is no facility for streaming data. For the intended use this is not a
problem. However it militates against using HTML::Macro for text
processing of very large datasets.
<loop id="people">
<tr><td>#first_name# #last_name#</td><td>#email#</td></tr>
view release on metacpan or search on metacpan
- basic test for leaks
- Slightly change the internal invoke_mason method for easier reuse
(Ask Bjørn Hansen)
0.52 October 22, 2010
- Add streaming handler, HTML::Mason::PSGIHandler::Streamy. (Chia-liang Kao)
0.51 October 18, 2010
- For body-less response, don't return an undef body element (Chia-liang Kao)
- Pass Mason -Status into psgi_header (Shawn M Moore)
view release on metacpan or search on metacpan
TableExtractor.pm view on Meta::CPAN
=head2 EXPORTS
=head2 CAVEATS, BUGS, and TODO
o parse() should handle other data sources, such as streaming, file handle
etc.
=head2 SEE ALSO
view release on metacpan or search on metacpan
lib/HTML/Zoom.pm view on Meta::CPAN
1;
=head1 NAME
HTML::Zoom - selector based streaming template engine
=head1 SYNOPSIS
use HTML::Zoom;
lib/HTML/Zoom.pm view on Meta::CPAN
having got this class itself at least somewhat documented I figured now was
a good time to cut a first real release.
=head1 DESCRIPTION
HTML::Zoom is a lazy, stream oriented, streaming capable, mostly functional,
CSS selector based semantic templating engine for HTML and HTML-like
document formats.
Which is, on the whole, a bit of a mouthful. So let me step back a moment
and explain why you care enough to understand what I mean:
lib/HTML/Zoom.pm view on Meta::CPAN
HTML::Zoom's filehandle object supports an additional event key, 'flush',
that is transparent to the rest of the system but indicates to the filehandle
object to end a getline operation at that point and return the HTML so far.
This means that in an environment where streaming output is available, such
as a number of the L<Plack> PSGI handlers, you can add the flush key to an
event in order to ensure that the HTML generated so far is flushed through
to the browser right now. This can be especially useful if you know you're
about to call a web service or a potentially slow database query or similar
to ensure that at least the header/layout of your page renders now, improving
lib/HTML/Zoom.pm view on Meta::CPAN
To which I say, "eh", "meh", and possibly also "feh". If it really upsets
you, either use extra classes for this (and remove them afterwards) or
use special fake elements or, well, honestly, just use something different.
L<Template::Semantic> provides a similar idea to zoom except using XPath
and XML::LibXML transforms rather than a lightweight streaming approach -
maybe you'd like that better. Or maybe you really did want
L<Template Toolkit|Template> after all. It is still damn good at what it does,
after all.
So far, however, I've found that for new sites the designers I'm working with
lib/HTML/Zoom.pm view on Meta::CPAN
=head2 GET THEE TO A SUMMARY!
Erm. Well.
HTML::Zoom is a lazy, stream oriented, streaming capable, mostly functional,
CSS selector based semantic templating engine for HTML and HTML-like
document formats.
But I said that already. Although hopefully by now you have some idea what I
meant when I said it. If you didn't have any idea the first time. I mean, I'm
view release on metacpan or search on metacpan
lib/HTTP/Daemon/Threaded/CGIAdapter.pm view on Meta::CPAN
<p>
Developers should be judicious in their use of the CGI interface for
HTTP::Daemon::Threaded: if the request is to return a very large (i.e.,
multi-megabyte) response, the underlying I/O buffering may consume
significant memory resources. Likewise, this package does not support
some methods of "Comet"-style streaming client-server interaction, as the
response buffer will not be dispatched to the client until the CGI
invokation has completed.
<p>
Copyright© 2008, Dean Arnold, Presicient Corp., USA<br>
All rights reserved.
view release on metacpan or search on metacpan
lib/HTTP/Engine/Interface/PSGI.pm view on Meta::CPAN
finalize => sub { _finalize(@_) },
},
},
;
sub can_has_streaming { 1 }
sub run {
my($self, $env) = @_;
# get PSGI response arrayrey. generated by _finalize
lib/HTTP/Engine/Interface/PSGI.pm view on Meta::CPAN
},
);
my $app = sub { $engine->run(@_) };
Plack::Loader->load('Standalone', port => 801)->run($app); # see L<Plack::Server::Standalone> and L<Plack::Loader>
if you want streaming response
use HTTP::Engine;
use IO::Handle::Util qw(io_from_getline); # see L<IO::Handle::Util>
use Plack::Loader;
my $count = 1;
view release on metacpan or search on metacpan
=pod
=head1 NAME
HTTP::Handle - HTTP Class designed for streaming
=head1 SYNOPSIS
use HTTP::Handle;
view release on metacpan or search on metacpan
t/mime.types view on Meta::CPAN
application/vnd.oasis.opendocument.text-template ott
application/vnd.oasis.opendocument.text-web oth
# application/vnd.obn
# application/vnd.oftn.l10n+json
# application/vnd.oipf.contentaccessdownload+xml
# application/vnd.oipf.contentaccessstreaming+xml
# application/vnd.oipf.cspg-hexbinary
# application/vnd.oipf.dae.svg+xml
# application/vnd.oipf.dae.xhtml+xml
# application/vnd.oipf.mippvcontrolmessage+xml
# application/vnd.oipf.pae.gem
view release on metacpan or search on metacpan
lib/HTTP/Request/StreamingUpload.pm view on Meta::CPAN
=for stopwords filepath callback chunked HeaderName HeaderValue fh
=head1 NAME
HTTP::Request::StreamingUpload - streaming upload wrapper for HTTP::Request
=head1 SYNOPSIS
=head2 upload from filepath
lib/HTTP/Request/StreamingUpload.pm view on Meta::CPAN
);
my $res = LWP::UserAgent->new->request($req);
=head1 DESCRIPTION
HTTP::Request::StreamingUpload is streaming upload wrapper for L<HTTP::Request>.
It could be alike when $DYNAMIC_FILE_UPLOAD of L<HTTP::Request::Common> was used.
However, it is works only for POST method with form-data.
HTTP::Request::StreamingUpload works on the all HTTP methods.
Of course, you can big file upload using few memory by this wrapper.
view release on metacpan or search on metacpan
lib/HTTP/Server/Simple/PSGI.pm view on Meta::CPAN
'psgi.input' => $self->stdin_handle,
'psgi.errors' => *STDERR,
'psgi.multithread' => 0,
'psgi.multiprocess' => 0,
'psgi.run_once' => 0,
'psgi.streaming' => 1,
'psgi.nonblocking' => 0,
'psgix.io' => $self->stdio_handle,
};
while (my ($k, $v) = each %ENV) {
view release on metacpan or search on metacpan
lib/Plack/Example/EventChat.pm view on Meta::CPAN
if( '/events' ne $path ) {
# Send the JS+HTML
return [ 200, ['Content-Type', 'text/html'], [$html] ]
};
if( ! $env->{"psgi.streaming"}) {
my $err= "Server does not support streaming responses";
warn $err;
return [ 500, ['Content-Type', 'text/plain'], [$err] ]
};
# immediately starts the response and stream the content
view release on metacpan or search on metacpan
lib/HTTP/Simple.pm view on Meta::CPAN
=head2 postfile
my $contents = postfile($url, $path);
my $contents = postfile($url, $path, $content_type);
Sends a POST request to the given URL, streaming the contents of the given
file. The content type is passed as C<application/octet-stream> if not
specified. Returns the response body as a byte string. Throws an exception on
connection, HTTP, or filesystem errors.
=head2 is_info
view release on metacpan or search on metacpan
lib/HTTP/StreamParser.pm view on Meta::CPAN
package HTTP::StreamParser;
# ABSTRACT: streaming HTTP parser
use strict;
use warnings;
use parent qw(Mixin::Event::Dispatch);
our $VERSION = '0.101';
=head1 NAME
HTTP::StreamParser - support for streaming HTTP request/response parsing
=head1 VERSION
version 0.101
lib/HTTP/StreamParser.pm view on Meta::CPAN
...
EOF
=head1 DESCRIPTION
Parses HTTP requests or responses. Generates events. Should be suitable for streaming.
You may be looking for L<HTTP::Parser::XS> instead - it's at least 20x faster than
this module. If you wanted something without XS, there's L<HTTP::Parser>.
Actual implementation is in L<HTTP::StreamParser::Request> or L<HTTP::StreamParser::Response>.
lib/HTTP/StreamParser.pm view on Meta::CPAN
=item * L<HTTP::Parser::XS> - used by several other modules, fast implementation, pure-Perl fallback,
but doesn't give access to the data until the headers have been parsed and aside from header count and
per-header size limitation, seems not to have any way to deal with oversized requests
=item * L<HTTP::Parser> - parses into L<HTTP::Request>/L<HTTP::Response> objects. Doesn't seem to guard
against large buffers but does have at least some support for streaming.
=item * L<HTTP::MessageParser> - also parses HTTP content
=item * L<Mojo::Message::Request> - part of L<Mojolicious>
view release on metacpan or search on metacpan
eg/seq-read.pl view on Meta::CPAN
use SequenceFileReader;
my $uri;
# change the protocol to tell which streaming lib to use
#$uri = 'file:///some/local/path/tmp/000000_0';
$uri = 'hdfs:///tmp/000000_0';
# or get it from the command line
view release on metacpan or search on metacpan
lib/Hadoop/Streaming.pm view on Meta::CPAN
http://hadoop.apache.org
=item Hadoop Streaming interface:
http://hadoop.apache.org/common/docs/r0.20.1/streaming.html
=item PAR::Packer
http://search.cpan.org/perldoc?PAR::Packer
lib/Hadoop/Streaming.pm view on Meta::CPAN
=item hadoop commandline
Run this in hadoop from the shell:
hadoop \
jar $streaming_jar_name \
-D mapred.job.name="my hadoop example" \
-input my_input_file \
-output my_output_hdfs_path \
-mapper my_mapper \
-combiner my_combiner \
-reducer my_reducer
$streaming_jar_name is the full path to the streaming jar provided by the installed hadoop. For my 0.20 install the path is:
/usr/lib/hadoop-0.20/contrib/streaming/hadoop-0.20.1+152-streaming.jar
The -D line is optional. If included, -D lines must come directly after the jar name and before other options.
For this hadoop job to work, the mapper, combiner and reducer must be full paths that are valid on each box in the hadoop cluster. There are a few ways to make this work.
lib/Hadoop/Streaming.pm view on Meta::CPAN
Additional files may be bundled into the hadoop jar via the '-files' option to hadoop jar. These files will be included in the jar that is distributed to each host. The files will be visible in the current working directory of the process. Subdire...
example:
hadoop \
jar $streaming_jar_name \
-D mapred.job.name="my hadoop example" \
-input my_input_file \
-output my_output_hdfs_path \
-mapper my_mapper \
-combiner my_combiner \
lib/Hadoop/Streaming.pm view on Meta::CPAN
* The mapper/reducer/combiner files can be included with the job via -file options to hadoop jar or they can be referenced directly if they are in the shared environment.
=item full path of shared file
hadoop \
jar $streaming_jar_name \
-input my_input_file \
-output my_output_hdfs_path \
-mapper /apps/perl5/bin/my_mapper \
-combiner /apps/perl5/bin/my_combiner \
-reducer /apps/perl5/bin/my_reducer
=item local path of included -file file
hadoop \
jar $streaming_jar_name \
-input my_input_file \
-output my_output_hdfs_path \
-file /apps/perl5/bin/my_mapper \
-file /apps/perl5/bin/my_combiner \
-file /apps/perl5/bin/my_reducer \
lib/Hadoop/Streaming.pm view on Meta::CPAN
Use pp (installed via PAR::Packer) to produce a perl file that needs only a perl interpreter to execute. I use -x option to run the my_mapper script on blank input, as this forces all of the necessary modules to be loaded and thus tracked in my PAR ...
mkdir packed
pp my_mapper -B -P -Ilib -o packed/my_mapper -x my_mapper < /dev/null
hadoop \
jar $streaming_jar_name \
-input my_input_file \
-output my_output_hdfs_path \
-file packed/my_mapper \
-mapper ./my_mapper
view release on metacpan or search on metacpan
Word/verb.txt view on Meta::CPAN
madden,maddened,maddened,maddens,maddening
magnetise,magnetised,magnetised,magnetises,magnetising
magnify,magnified,magnified,magnifies,magnifying
mail,mailed,mailed,mails,mailing
maim,maimed,maimed,maims,maiming
mainstream,mainstreamed,mainstreamed,mainstreams,mainstreaming
maintain,maintained,maintained,maintains,maintaining
make,made,made,makes,making
make,made,made,maketh,making
malfunction,malfunctioned,malfunctioned,malfunctions,malfunctioning
malign,maligned,maligned,maligns,maligning
Word/verb.txt view on Meta::CPAN
strangle,strangled,strangled,strangles,strangling
strap,strapped,strapped,straps,strapping
stratify,stratified,stratified,stratifies,stratifying
stray,strayed,strayed,strays,straying
streak,streaked,streaked,streaks,streaking
stream,streamed,streamed,streams,streaming
streamline,streamlined,streamlined,streamlines,streamlining
strengthen,strengthened,strengthened,strengthens,strengthening
stress,stressed,stressed,stresses,stressing
stretch,stretched,stretched,stretches,stretching
stretche,stretched,stretched,stretches,stretching
view release on metacpan or search on metacpan
share/root/static/yui/build/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/App/Horris/CLI/Command/twitter_stream.pm view on Meta::CPAN
package App::Horris::CLI::Command::twitter_stream;
# ABSTRACT: anyevent twitter streaming script
use Moose;
use Config::General qw/ParseConfig/;
use DBI;
lib/App/Horris/CLI/Command/twitter_stream.pm view on Meta::CPAN
=encoding utf-8
=head1 NAME
App::Horris::CLI::Command::twitter_stream - anyevent twitter streaming script
=head1 VERSION
version v0.1.2
view release on metacpan or search on metacpan
lib/Hyperscan/Database.pm view on Meta::CPAN
L<hs_open_stream|https://intel.github.io/hyperscan/dev-reference/api_files.html#c.hs_open_stream>
=head3 scan( $data, $flags, $scratch, $callback )
The block (non-streaming) regular expression scanner.
L<hs_scan|https://intel.github.io/hyperscan/dev-reference/api_files.html#c.hs_scan>
=head3 scan_vector( $data, $flags, $scratch, $callback )
view release on metacpan or search on metacpan
lib/IO/Async/XMLStream/SAXReader.pm view on Meta::CPAN
);
$loop->add($sax);
$loop->run();
This sub-classes L<< C<IO::Async::Stream>|IO::Async::Stream >> to provide a streaming SAX parser.
For the individual C<SAX> events that can be listened for, see L<< C<XML::SAX::Base>|XML::SAX::Base >>.
All are prefixed with the C<on_> prefix as constructor arguments.
view release on metacpan or search on metacpan
brotli/c/dec/state.h view on Meta::CPAN
Distributed under MIT license.
See file LICENSE for detail or copy at https://opensource.org/licenses/MIT
*/
/* Brotli state for partial streaming decoding. */
#ifndef BROTLI_DEC_STATE_H_
#define BROTLI_DEC_STATE_H_
#include "../common/constants.h"
view release on metacpan or search on metacpan
lib/IO/Compress/Lzf.pm view on Meta::CPAN
Here are a few example that show the capabilities of the module.
=head3 Streaming
This very simple command line example demonstrates the streaming capabilities of the module.
The code reads data from STDIN, compresses it, and writes the compressed data to STDOUT.
$ echo hello world | perl -MIO::Compress::Lzf=lzf -e 'lzf \*STDIN => \*STDOUT' >output.lzf
The special filename "-" can be used as a standin for both C<\*STDIN> and C<\*STDOUT>,
lib/IO/Compress/Lzf.pm view on Meta::CPAN
=head2 Examples
=head3 Streaming
This very simple command line example demonstrates the streaming capabilities
of the module. The code reads data from STDIN or all the files given on the
commandline, compresses it, and writes the compressed data to STDOUT.
use strict ;
use warnings ;
view release on metacpan or search on metacpan
lib/IO/Compress/Lzip.pm view on Meta::CPAN
Here are a few example that show the capabilities of the module.
=head3 Streaming
This very simple command line example demonstrates the streaming capabilities of the module.
The code reads data from STDIN, compresses it, and writes the compressed data to STDOUT.
$ echo hello world | perl -MIO::Compress::Lzip=lzip -e 'lzip \*STDIN => \*STDOUT' >output.lz
The special filename "-" can be used as a standin for both C<\*STDIN> and C<\*STDOUT>,
lib/IO/Compress/Lzip.pm view on Meta::CPAN
=head2 Examples
=head3 Streaming
This very simple command line example demonstrates the streaming capabilities
of the module. The code reads data from STDIN or all the files given on the
commandline, compresses it, and writes the compressed data to STDOUT.
use strict ;
use warnings ;
view release on metacpan or search on metacpan
lib/IO/Compress/Lzop.pm view on Meta::CPAN
Here are a few example that show the capabilities of the module.
=head3 Streaming
This very simple command line example demonstrates the streaming capabilities of the module.
The code reads data from STDIN, compresses it, and writes the compressed data to STDOUT.
$ echo hello world | perl -MIO::Compress::Lzop=lzop -e 'lzop \*STDIN => \*STDOUT' >output.lzo
The special filename "-" can be used as a standin for both C<\*STDIN> and C<\*STDOUT>,
lib/IO/Compress/Lzop.pm view on Meta::CPAN
=head2 Examples
=head3 Streaming
This very simple command line example demonstrates the streaming capabilities
of the module. The code reads data from STDIN or all the files given on the
commandline, compresses it, and writes the compressed data to STDOUT.
use strict ;
use warnings ;
view release on metacpan or search on metacpan
lib/IO/Compress/Bzip2.pm view on Meta::CPAN
Here are a few example that show the capabilities of the module.
=head3 Streaming
This very simple command line example demonstrates the streaming capabilities of the module.
The code reads data from STDIN, compresses it, and writes the compressed data to STDOUT.
$ echo hello world | perl -MIO::Compress::Bzip2=bzip2 -e 'bzip2 \*STDIN => \*STDOUT' >output.bz2
The special filename "-" can be used as a standin for both C<\*STDIN> and C<\*STDOUT>,
lib/IO/Compress/Bzip2.pm view on Meta::CPAN
=head2 Examples
=head3 Streaming
This very simple command line example demonstrates the streaming capabilities
of the module. The code reads data from STDIN or all the files given on the
commandline, compresses it, and writes the compressed data to STDOUT.
use strict ;
use warnings ;