Result:
found more than 672 distributions - search limited to the first 2001 files matching your query
( run in 0.572 )
CPAN-IndexPod
view release on metacpan or search on metacpan
t/unpacked/GraphViz/Changes view on Meta::CPAN
work under Win32!
- this is the Flight 63 edition
1.4 Wed Oct 3 07:57:42 BST 2001
- added new filehandle, scalar reference, and code reference
scheme to as_* to allow streaming of data, rather than
accumulating potentially very large output in memory (based
on patch by Dave Rolsky)
- new pagewidth and pageheight graph attributes for creating
PostScript mosaics of large graphs (idea by Nelson Loyola)
CPAN-Testers-API
view release on metacpan or search on metacpan
lib/CPAN/Testers/API.pm view on Meta::CPAN
#pod
#pod C<$processor> is an optional subref that allows for processing each row
#pod before it is written. Use this to translate column names or values into
#pod the format the API expects.
#pod
#pod For this to work usefully behind Fastly, we also need to enable streaming
#pod miss so that Fastly streams the data to the end-user as it gets it:
#pod L<https://docs.fastly.com/guides/performance-tuning/improving-caching-performance-with-large-files#streaming-miss>.
#pod
#pod =cut
sub stream_rs {
my ( $c, $rs, $process ) = @_;
lib/CPAN/Testers/API.pm view on Meta::CPAN
C<$processor> is an optional subref that allows for processing each row
before it is written. Use this to translate column names or values into
the format the API expects.
For this to work usefully behind Fastly, we also need to enable streaming
miss so that Fastly streams the data to the end-user as it gets it:
L<https://docs.fastly.com/guides/performance-tuning/improving-caching-performance-with-large-files#streaming-miss>.
=head1 CONFIG
This application can be configured by setting the C<MOJO_CONFIG>
environment variable to the path to a configuration file. The
CPAN-cpanminus-reporter-RetainReports
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
CPAN
view release on metacpan or search on metacpan
distroprefs/BINGOS.POE-Component-Server-SimpleHTTP.yml view on Meta::CPAN
talk:
- "Do you want SSL support"
- "n\n"
- "Do you want PreFork support"
- "y\n"
- "Do you want to test streaming"
- "y\n"
CPP-Boost-Mini
view release on metacpan or search on metacpan
include/boost/blank.hpp view on Meta::CPAN
inline bool operator>(const blank&, const blank&)
{
return false;
}
// streaming support
//
#if !defined(BOOST_NO_IOSTREAM)
BOOST_TEMPLATED_STREAM_TEMPLATE(E,T)
inline BOOST_TEMPLATED_STREAM(ostream, E,T)& operator<<(
CPP-catch-test
view release on metacpan or search on metacpan
src/catch.hpp view on Meta::CPAN
void throwLogicError( std::string const& message, SourceLineInfo const& locationInfo );
void seedRng( IConfig const& config );
unsigned int rngSeed();
// Use this in variadic streaming macros to allow
// >> +StreamEndStop
// as well as
// >> stuff +StreamEndStop
struct StreamEndStop {
std::string operator+() {
CPP-catch
view release on metacpan or search on metacpan
src/catch.hpp view on Meta::CPAN
std::size_t line;
};
std::ostream& operator << ( std::ostream& os, SourceLineInfo const& info );
// Use this in variadic streaming macros to allow
// >> +StreamEndStop
// as well as
// >> stuff +StreamEndStop
struct StreamEndStop {
std::string operator+() const;
CVSUtils
view release on metacpan or search on metacpan
date: 2000/08/18 21:44:36; author: sussman; state: Exp; lines: +6 -7
comments update
----------------------------
revision 1.42
date: 2000/08/18 21:30:29; author: sussman; state: Exp; lines: +106 -19
New interface for optionally streaming prop-deltas.
----------------------------
revision 1.41
date: 2000/08/18 00:49:50; author: kfogel; state: Exp; lines: +6 -6
Making WC library use the new stuff in delta library:
Tweaked #includes and Makefiles as appropriate, and defined skeleton
functions.
----------------------------
revision 1.4
date: 2000/08/14 23:17:41; author: kfogel; state: Exp; lines: +1 -1
Rewrite to use the callee-push streaming interface.
This commit is _not_ going to compile, so don't even try.
----------------------------
revision 1.3
date: 2000/08/08 23:22:13; author: kfogel; state: Exp; lines: +0 -1
date: 2000/08/21 23:37:06; author: kfogel; state: Exp; lines: +2 -2
Many changes to do with creating administrative subdirs.
----------------------------
revision 1.29
date: 2000/08/14 23:17:41; author: kfogel; state: Exp; lines: +35 -18
Rewrite to use the callee-push streaming interface.
This commit is _not_ going to compile, so don't even try.
----------------------------
revision 1.28
date: 2000/08/03 21:11:42; author: kfogel; state: Exp; lines: +54 -72
date: 2000/08/14 23:19:10; author: kfogel; state: Exp; lines: +7 -0
Plug in new finish_file() callback.
----------------------------
revision 1.1
date: 2000/08/14 23:17:41; author: kfogel; state: Exp;
Rewrite to use the callee-push streaming interface.
This commit is _not_ going to compile, so don't even try.
=============================================================================
RCS file: /cvs/subversion/subversion/libsvn_wc/Attic/deltaparse.c,v
total revisions: 12; selected revisions: 12
description:
----------------------------
revision 1.12
date: 2000/08/14 23:17:41; author: kfogel; state: dead; lines: +0 -0
Rewrite to use the callee-push streaming interface.
This commit is _not_ going to compile, so don't even try.
----------------------------
revision 1.11
date: 2000/08/09 15:29:32; author: sussman; state: Exp; lines: +10 -1
Tweaked #includes and Makefiles as appropriate, and defined skeleton
functions.
----------------------------
revision 1.2
date: 2000/08/14 23:17:43; author: kfogel; state: Exp; lines: +35 -1
Rewrite to use the callee-push streaming interface.
This commit is _not_ going to compile, so don't even try.
----------------------------
revision 1.1
date: 2000/08/08 16:23:28; author: kfogel; state: Exp;
Caffeinated_Markup_Language
view release on metacpan or search on metacpan
t/documents.t view on Meta::CPAN
use Test::More;
use Test::Exception;
use Text::CaffeinatedMarkup::HTMLFormatter;
my $data = "Yup, we're here! Caffeinated Panda Creations has launched the first phase of our new website.\n\nRight now as you can see the blog is up and running and we'll be using it to keep you up to date with projects, events we're involved with, a...
my $formatter = Text::CaffeinatedMarkup::HTMLFormatter->new;
lives_ok{$formatter->format($data)} "Document #1 parse ok";
done_testing();
Cairo
view release on metacpan or search on metacpan
* Remove the wrappers for cairo_pdf_surface_set_dpi and
cairo_ps_surface_set_dpi. Developers should use
cairo_surface_set_fallback_resolution instead.
* Improve the enum converters to produce more useful error messages.
* Wrap the streaming functions:
- cairo_surface_write_to_png_stream
- cairo_image_surface_create_from_png_stream
- cairo_pdf_surface_create_for_stream
- cairo_ps_surface_create_for_stream
* Wrap new API:
Catalyst-Action-FromPSGI
view release on metacpan or search on metacpan
Revision history for Catalyst-Action-FromPSGI
0.001006 2014-08-04 20:59:58-05:00 America/Chicago
- Make streaming/deferal work by leveraging Catalyst from October 2013
(Thanks Thomas Sibley!)
0.001005 2013-09-18 15:56:55 America/Chicago
- Fixed yet another psgi.input issue (thanks Wes Malone for finding this)
Catalyst-Engine-Apache
view release on metacpan or search on metacpan
t/lib/TestApp/Controller/Action/Streaming.pm view on Meta::CPAN
package TestApp::Controller::Action::Streaming;
use strict;
use base 'TestApp::Controller::Action';
sub streaming : Global {
my ( $self, $c ) = @_;
for my $line ( split "\n", <<'EOF' ) {
foo
bar
baz
Catalyst-Engine-HTTP-POE
view release on metacpan or search on metacpan
t/lib/TestApp/Controller/Action/Streaming.pm view on Meta::CPAN
package TestApp::Controller::Action::Streaming;
use strict;
use base 'TestApp::Controller::Action';
sub streaming : Global {
my ( $self, $c ) = @_;
for my $line ( split "\n", <<'EOF' ) {
foo
bar
baz
Catalyst-Engine-HTTP-Prefork
view release on metacpan or search on metacpan
t/lib/TestApp/Controller/Action/Streaming.pm view on Meta::CPAN
package TestApp::Controller::Action::Streaming;
use strict;
use base 'TestApp::Controller::Action';
sub streaming : Global {
my ( $self, $c ) = @_;
for my $line ( split "\n", <<'EOF' ) {
foo
bar
baz
Catalyst-Engine-PSGI
view release on metacpan or search on metacpan
lib/Catalyst/Engine/PSGI.pm view on Meta::CPAN
=item *
Your application is supposed to work with any PSGI servers without any
code modifications, but if your application uses C<< $c->res->write >>
to do streaming write, this engine will buffer the ouput until your
app finishes.
To do real streaming with this engine, you should implement an
IO::Handle-like object that responds to C<getline> method that returns
chunk or undef when done, and set that object to C<< $c->res->body >>.
Alternatively, it is possible to set the body to a code reference,
which will be used to stream content as documented in the
Catalyst-Plugin-Session-State-Cookie
view release on metacpan or search on metacpan
0.10 2009-02-08
- POD addition.
- Switch from NEXT to MRO::Compat
0.09 2007-10-08
- Bump dependencies so that streaming a file also causes the cookie to
be updated.
- Add tests for this
0.08 2007-09-14
- Fix live test with Mech version 0.37+
Catalyst-Plugin-Session-Store-Cookie
view release on metacpan or search on metacpan
lib/Catalyst/Plugin/Session/Store/Cookie.pm view on Meta::CPAN
a bunch of stuff into the user session, this will likely not work out.
B<NOTE> Since we need to store all the session info in the cookie, the session
state will be set at ->finalize_headers stage (rather than at ->finalize_body
which is the default for session storage plugins). What this means is that if
you use the streaming or socket interfaces ($c->response->write, $c->response->write_fh
and $c->req->io_fh) your session state will get saved early. For example you
cannot do this:
$c->res->write("some stuff");
$c->session->{key} = "value";
Catalyst-Plugin-Session
view release on metacpan or search on metacpan
lib/Catalyst/Plugin/Session/Store.pm view on Meta::CPAN
However some storage plugins may wish to finalize earlier, during header
finalization. For example a storage that saved state in a client cookie
would wish this. If a storage plugin wants to finalize early it should set
$c->_needs_early_session_finalization to true. Please note that if you
do this in a storage plugin, you should warn users not to attempt to change
or add session keys if you use a streaming or socket interface such as
$c->res->write, $c->res->write_fh or $c->req->io_fh.
=cut
Catalyst-Runtime
view release on metacpan or search on metacpan
lib/Catalyst.pm view on Meta::CPAN
Make sure your body is encoded properly IF you set an encoding. By
default the encoding is UTF-8 but you can disable it by explicitly setting the
encoding configuration value to undef.
We can only encode when the body is a scalar. Methods for encoding via the
streaming interfaces (such as C<write> and C<write_fh> on L<Catalyst::Response>
are available).
See L</ENCODING>.
=cut
CatalystX-Crudite
view release on metacpan or search on metacpan
lib/CatalystX/Crudite/Util/Random.pm view on Meta::CPAN
streaks
stream
streamed
streamer
streamers
streaming
streamline
streamlined
streamliner
streamlines
streamlining
Catmandu-RDF
view release on metacpan or search on metacpan
Changelog for Catmandu-RDF
0.32 2017-08-29 13:23:32 CEST
- Fixing SPARQL examples with latest RDF::LDF
- Better support for streaming RDF input
- Adding a --speed option to the Catmandu::Importer::RDF
0.31 2016-04-13 10:24:55 CEST
- Fix test failure caused by RDF::NS (#29)
0.29 2016-03-30 14:28:27 CEST
- provide caching support for HTTP access
0.28 2015-11-25 11:35:42 CET
- streaming export in NTriples format by default (issue #25)
0.27 2015-05-30 14:15:45 CEST
- added sparql file option (issue #19)
0.26 2015-05-21 10:38:12 CEST
- added support of Linked Data Fragments
0.25 2015-03-27 13:53:59 CET
- support streaming of NTriple data
0.24 2015-03-09 13:20:23 CET
- added support of SPARQL
- fixed some unit tests
- rewrote aref_query fix
Catmandu
view release on metacpan or search on metacpan
t/Catmandu-Exporter-Text.t view on Meta::CPAN
);
isa_ok $exporter, 'Catmandu::Exporter::Text';
$exporter->add_many($data);
# don't call commit to test streaming output
is $exporter->count, 3, 'Count ok';
is $file, "moose\tpony\tshrimp,lobster\t", 'Text doc array';
}
Chart-Clicker
view release on metacpan or search on metacpan
lib/Chart/Clicker.pm view on Meta::CPAN
Get the dataset at the specified index.
=head2 rendered_data
Returns the data for this chart as a scalar. Suitable for 'streaming' to a
client.
=head2 add_to_over_decorations
Add an over decoration to the list.
Chatbot-Alpha
view release on metacpan or search on metacpan
lib/Chatbot/Alpha.pm view on Meta::CPAN
the stream cache will be loaded (assuming FILE_PATH is omitted). You shouldn't need to worry about using STREAM, see
the "stream" method below.
=head2 stream (ALPHA_CODE)
Inputs a set of Alpha code directly into the module ("streaming") rather than loading it from an external document.
See synopsis for an example.
=head2 sortReplies
Sorts the replies already loaded: solid triggers go first, followed by triggers containing wildcards. If you fail to
Clio
view release on metacpan or search on metacpan
lib/Clio/Server/HTTP/Client/Stream.pm view on Meta::CPAN
$Clio::Server::HTTP::Client::Stream::AUTHORITY = 'cpan:AJGB';
}
{
$Clio::Server::HTTP::Client::Stream::VERSION = '0.02';
}
# ABSTRACT: Clio HTTP Client for streaming connections
use strict;
use Moo;
use Scalar::Util qw( blessed );
lib/Clio/Server/HTTP/Client/Stream.pm view on Meta::CPAN
=encoding utf-8
=head1 NAME
Clio::Server::HTTP::Client::Stream - Clio HTTP Client for streaming connections
=head1 VERSION
version 0.02
=head1 DESCRIPTION
# HTTP server with streaming clients
<Server>
Listen 0:12345
Class HTTP
lib/Clio/Server/HTTP/Client/Stream.pm view on Meta::CPAN
OutputFilter LineEnd
</Client>
</Server>
HTTP server with streaming capabilities.
Process output is streamed directly to client - the above example can be used
directly in a browser for read only data.
Extends of L<Clio::Client>.
Collection
view release on metacpan or search on metacpan
lib/Collection/AutoSQL.pm view on Meta::CPAN
Return list of ids
params:
flow - Flow:: object for streaming results
onpage - [pagination] count of ids on page
page - [pagination] requested page ( depend on onpage)
exp - ref to expression for select
desc - revert sorting ([1,0])
where - custom where if needed, instead expr ['where sring', $query_param1,..]
Comedi-Lib
view release on metacpan or search on metacpan
return lib_find_subdevice_by_type($self->{handle}, $type, $start);
}
=item get_read_subdevice
Find streaming input subdevice.
Example code,
my $streaming_input_support = $cref->get_read_subdevice();
if ($streaming_input_support == -1) {
print "No streaming input support available\n";
}
else {
print "Comedi subdevice no. $streaming_input_support ",
"allows streaming input\n";
}
This class method returns the subdevice whose streaming input buffer is
accessible through the previous opened device. If there is no such subdevice,
-1 is returned.
=cut
return lib_get_read_subdevice($self->{handle});
}
=item get_write_subdevice
Find streaming output subdevice.
Example code,
my $streaming_output_support = $cref->get_write_subdevice();
if ($streaming_output_support == -1) {
print "No streaming output support available\n";
}
else {
print "Comedi subdevice no. $streaming_output_support ",
"allows streaming output\n";
}
This class method returns the subdevice whose streaming output buffer is
accessible through the previous opened device. If there is no such subdevice,
-1 is returned.
=cut
my $buf_size = $cref->get_buffer_size($subdev);
croak "An error has occurred" if $buf_size == -1;
print "Streaming buffer size for the subdevice - $buf_size Bytes\n";
This class method returns the size -in Bytes- of the streaming buffer for the
specified subdevice. On error, -1 is returned.
=cut
sub get_buffer_size {
return lib_get_buffer_size($self->{handle}, $subdev);
}
=item get_max_buffer_size
Maximum streaming buffer size.
Example code,
my $max_size = $cref->get_max_buffer_size($subdev);
croak "An error has occurred" if $max_size == -1;
print "Max. streaming buffer size for the subdevice - $max_size Bytes\n";
This class method returns the maximum allowable size -in Bytes- of the
streaming buffer for the specified subdevice. On error, -1 is returned.
=cut
sub get_max_buffer_size {
my $self = shift;
require POSIX;
my $vmps = POSIX::sysconf(&POSIX::_SC_PAGESIZE);
$vmps *= 2;
print "Trying to set the streaming buffer size to $vmps\n";
if ($cref->set_buffer_size($subdev, $vmps) == -1) {
print "Warning: Couldn't set new streaming buffer size\n";
}
The C<set_buffer_size()> class method returns the new buffer size in Bytes.
On error, -1 is returned.
return;
}
=item cancel
Stop streaming input/output in progress.
Example code,
# This class method is useful in combination with command()
# and this class method is not completely implemented yet.
return lib_cancel($self->{handle}, $subdev);
}
=item command
Start streaming input/output.
Note that this subroutine has no functionality as long as I have no testing
device with the associated driver.
Patches or suggestions are welcome, send me an email (Subject: Comedi::Lib).
return;
}
=item command_test
Test streaming input/output configuration.
Note that this subroutine has no functionality as long as I have no testing
device with the associated driver.
Patches or suggestions are welcome, send me an email (Subject: Comedi::Lib).
return;
}
=item poll
Force updating of streaming buffer.
Example code,
my $retval = $cref->poll($subdev);
croak "An error has occurred" if $retval == -1;
# This class method is useful in combination with command()
# and this class method is not completely implemented yet.
This class method returns the number of bytes that are available in the
streaming buffer. If there is an error, -1 is returned.
=cut
sub get_buffer_contents {
print STDERR __PACKAGE__, '::',
# This class method is useful in combination with command()
# and this class method is not completely implemented yet.
This class method returns the offset in bytes of the read pointer in the
streaming buffer. If there is an error, -1 is returned.
=cut
sub get_buffer_offset {
print STDERR __PACKAGE__, '::',
Compiler-Parser
view release on metacpan or search on metacpan
t/app/Plack/Handler/Apache1.t view on Meta::CPAN
],
},
},
},
right => branch { '=>',
left => leaf 'psgi.streaming',
right => function_call { 'Plack::Util::TRUE',
args => [
],
},
},
t/app/Plack/Handler/Apache1.t view on Meta::CPAN
'psgi.input' => $r,
'psgi.errors' => *STDERR,
'psgi.multithread' => Plack::Util::FALSE,
'psgi.multiprocess' => Plack::Util::TRUE,
'psgi.run_once' => Plack::Util::FALSE,
'psgi.streaming' => Plack::Util::TRUE,
'psgi.nonblocking' => Plack::Util::FALSE,
'psgix.harakiri' => Plack::Util::TRUE,
};
if (defined(my $HTTP_AUTHORIZATION = $r->headers_in->{Authorization})) {
Compress-BGZF
view release on metacpan or search on metacpan
lib/Compress/BGZF/Reader.pm view on Meta::CPAN
$reader->write_index( $fn_idx );
=head1 DESCRIPTION
C<Compress::BGZF::Reader> is a module implementing random access to the BGZIP file
format. While it can do sequential/streaming reads, there is really no point
in using it for this purpose over standard GZIP tools/libraries, since BGZIP
is GZIP-compatible.
There are two main modes of construction - as an object (using C<new()>) and
as a filehandle glob (using C<new_filehandle>). The filehandle mode is
Compress-Bzip2
view release on metacpan or search on metacpan
lib/Compress/Bzip2.pm view on Meta::CPAN
Note that each such block has an overhead of leading and trailing
synchronization bytes. bzip2 recovery uses this information to
pull useable data out of a corrupted file.
A streaming application would probably want to set the blocking low.
=item B<-workFactor>
For bzip object opened for stream deflation or write.
lib/Compress/Bzip2.pm view on Meta::CPAN
=head1 Compress::Bzip2 1.03 COMPATIBILITY
While the 2.x thread forked off of 1.00, another line of development
came to a head at 1.03. The 1.03 version worked with bzlib 1.0.2, had
improvements to the error handling, single buffer inflate/deflate, a
streaming interface to inflate/deflate, and a cpan style test suite.
=head2 B<$dest = compress( $string, [$level] )>
Alias to L<memBzip>, this compresses string, using the optional
compression level, 1 through 9, the default being 6. Returns a string
lib/Compress/Bzip2.pm view on Meta::CPAN
Note that each such block has an overhead of leading and trailing
synchronization bytes. bzip2 recovery uses this information to
pull useable data out of a corrupted file.
A streaming application would probably want to set the blocking low.
=item B<-workFactor>
The workFactor setting tells the deflation algorithm how much work
to invest to compensate for repetitive data.
lib/Compress/Bzip2.pm view on Meta::CPAN
I<Compress::Bzip2> was subsequently passed on to Marco Carnut
F<kiko@tempest.com.br> who shepherded it through to version 1.03, a
set of changes which included upgrades to handle bzlib 1.0.2, and
improvements to the in memory inflate and deflate routines. The
streaming interface and error information were added by David Robins
F<dbrobins@davidrobins.net>.
Version 2 of I<Compress::Bzip2> is due to Rob Janes, of
arjay@cpan.org. This release is intended to give an interface
close to that of Compress::Zlib. It's development forks from 1.00,
not 1.03, so the streaming interface is not the same as that in 1.03,
although apparently compatible as it passes the 1.03 test suite.
Minor subsequent fixes and releases were done by Reini Urban,
rurban@cpan.org.
( run in 0.572 second using v1.01-cache-2.11-cpan-a5abf4f5562 )