streaming results from the CPAN

	  psgi.errors
	  psgi.multithread
	  psgi.multiprocess
	  psgi.run_once
	  psgi.nonblocking
	  psgi.streaming
	  psgix.session
	  psgix.session.options
	  psgix.logger
       /;
}

view all matches for this distribution

MP3-Icecast

2 results

Icecast.pm view on Meta::CPAN

  }


=head1 ABSTRACT

MP3::Icecast supports streaming Icecast protocol over socket
or other filehandle (including STDIN).  This is useful for writing
a streaming media server.

MP3::Icecast also includes support for generating M3U and PLSv2
playlist files.  These are common formats supported by most modern
media players, including XMMS, Windows Media Player 9, and Winamp.

Icecast.pm view on Meta::CPAN

           third argument is given, in which case ->print() is
           called on the second argument.  An IO::Handle or
           Apache instance will work here.
 Returns : true on success, false on failure
 Args    : 1) system path to the file to stream
           2) offset in file to start streaming
           3) (optional) object to call ->print() on, rather
              than printing to STDOUT


=cut

view all matches for this distribution

MPEG-Audio-Frame

1 match

lib/MPEG/Audio/Frame.pm view on Meta::CPAN

=head1 DESCRIPTION

A very simple, pure Perl module which allows parsing out data from mp3 files,
or streams, and chunking them up into different frames. You can use this to
accurately determine the length of an mp3, filter nonaudio data, or chunk up
the file for streaming via datagram. Virtually anything is possible.

=head1 MPEG FORMAT SUPPORT

L<MPEG::Audio::Frame> supports various types of MPEG data.

view all matches for this distribution

MQdb

1 match

lib/MQdb/DBStream.pm view on Meta::CPAN


MQdb::DBStream - DESCRIPTION of Object

=head1 SYNOPSIS

A simplified object to manage a collection of information related to streaming data from
a database.  at least with MYSQL, the perl driver does odd caching so to stream one
needs to create a new database connection in order to stream

=head1 DESCRIPTION

lib/MQdb/DBStream.pm view on Meta::CPAN


=head2 set_stream_useresult_behaviour

  Description  : sets a global behaviour for all DBStreams.  
                 setting use_result to "on" will leave the results on the database and
                 will keep the database connection open durring streaming.  
                 Both methods have similar speed performance, but keeping the results 
                 on the database server means the client uses essentially no memory.
                 The risk of turning this on is that the the database connection remains open
                 and there is risk of it timing out if processing takes a long time to stream all data.
                 When turned off, the entire result set is transfered in bulk to the driver (DBD::mysql)
                 and streaming happens from the underlying driver code and the perl code layer.
                 Default is "off" since this is safer but one risks needing lots of memory on the client.
  Parameter[1] : 1 or "y" or "on" turns the use_result on and keeps the database connection open
  Returntype   : none
  Exceptions   : none
  Example      : MQdb::DBStream->set_stream_useresult_behaviour(1);

lib/MQdb/DBStream.pm view on Meta::CPAN

=head2 stream_database

  Description: this is an internal system method.  
               Needs to have two database connections open, one for the active
               stream handle, and one for lazy-loading additional data on the returned 
               objects.  This is used to set the database which is the one streaming objects
  Arg (1)    : $database (MQdb::Database) for setting
  Returntype : MQdb::Database
  Exceptions : none
  Callers    :  MQdb::MappedQuery

view all matches for this distribution

Mac-Carbon

1 match

AppleEvents/AppleEvents.xs view on Meta::CPAN


MODULE = Mac::AppleEvents	PACKAGE = AEStream 

=head2 AEStream

The Apple Event Gizmos streams approach uses a streaming model for building 
a sequence of descriptors.

=over 4

=item new AEStream

AppleEvents/AppleEvents.xs view on Meta::CPAN

	stream
	RETVAL

=item Abort STREAM

Abort the streaming process, and close it out.

	$stream->Abort;

=cut
MacOSRet

view all matches for this distribution

Mac-Errors

2 results

lib/Mac/Errors.pm view on Meta::CPAN


sub errAEDuplicateHandler { -1736 }

=item errAEStreamBadNesting

 nesting violation while streaming

=cut

sub errAEStreamBadNesting { -1737 }

lib/Mac/Errors.pm view on Meta::CPAN


=cut

sub noMemoryNodeFailedInitialize { -30552 }

=item streamingNodeNotReadyErr

=cut

sub streamingNodeNotReadyErr { -30553 }

=item qtvrLibraryLoadErr

=cut

view all matches for this distribution

Mail-SpamAssassin

1 match

lib/Mail/SpamAssassin/Plugin/OLEVBMacro.pm view on Meta::CPAN


=back

=cut

  # https://blogs.msdn.microsoft.com/vsofficedeveloper/2008/05/08/office-2007-file-format-mime-types-for-http-content-streaming-2/
  # https://technet.microsoft.com/en-us/library/ee309278(office.12).aspx

  push(@cmds, {
    setting => 'olemacro_exts',
    default => qr/(?:doc|docx|dot|pot|ppa|pps|ppt|rtf|sldm|xl|xla|xls|xlsx|xlt|xltx|xslb)$/,

view all matches for this distribution

Markdent

1 match

Changes view on Meta::CPAN



0.18   2012-03-04

- The Markdent::Handler::HTMLStream::Document and ::Fragment modules did not
  detect when streaming to a file handle failed. This is because HTML::Stream
  does not check that it's calls to ->print succeed. This has been fixed by
  wrapping file handles (native or IO::Handle) in an object which checks that
  print succeeds.

- Distro/packaging cleanup.

view all matches for this distribution

MarpaX-ESLIF

2 results

lib/MarpaX/ESLIF.pm view on Meta::CPAN


Matching supports natively regular expression using the L<PCRE2|http://www.pcre.org/> library.

=item Streaming

Native support of streaming input.

=item Sub-grammars

The number of sub grammars is unlimited.

view all matches for this distribution

Mason

1 match

lib/Mason/Manual/Components.pod view on Meta::CPAN


=head2 Output versus return value

Most Mason methods output content such as HTML. The content is not actually
returned, but is instead appended to an implicit buffer. This is slightly more
complicated but is necessary for supporting streaming applications.

When Mason generates C<main> and other methods declared with C<< <%method> >>,
it puts an implicit

    return undef;

view all matches for this distribution

Mastodon-Client

4 results


  my $endpoint
    = $self->instance->uri
    . '/api/v'
    . $self->api_version
    . '/streaming/'
    . (( $query =~ /^#/ )
        ? ( 'hashtag?' . $query )
        : $query
      );

  $listener->start;

=head1 DESCRIPTION

Mastodon::Client lets you talk to a Mastodon server to obtain authentication
credentials, read posts from timelines in both static or streaming mode, and
perform all the other operations exposed by the Mastodon API.

Most of these are available through the convenience methods listed below, which
validate input parameters and are likely to provide more meaningful feedback in
case of errors.


=back

=head1 STREAMING RESULTS

Alternatively, it is possible to use the streaming API to get a constant stream
of updates. To do this, there is the B<stream()> method.

=over 4

=item B<stream($query)>

the particular tag.

For more details on how to use this object, see the documentation for
L<Mastodon::Listener>.

Accessing streaming public timeline does not require authentication.

=back

=head1 REQUEST METHODS

view all matches for this distribution

Math-LiveStats

5 results

lib/Math/LiveStats.pm view on Meta::CPAN


# perl -MPod::Markdown -e 'Pod::Markdown->new->filter(@ARGV)' lib/Math/LiveStats.pm  > README.md

=head1 NAME

Math::LiveStats - Pure perl module to make mean, standard deviation, vwap, and p-values available for one or more window sizes in streaming data

=head1 SYNOPSIS


    #!/usr/bin/perl -w

lib/Math/LiveStats.pm view on Meta::CPAN

    cat data | perl -MMath::LiveStats -ne 'BEGIN{$s=Math::LiveStats->new(20);} chomp;($t,$p,$v)=split(/,/); $s->add($t,$p,$v); print "$t,$p,$v,",$s->n(20),",",$s->mean(20),",",$s->stddev(20),",",$s->vwap(20),",",$s->vwapdev(20),"\n"'

=head1 DESCRIPTION

Math::LiveStats provides live statistical calculations (mean, standard deviation, p-value,
volume-weighted-average-price and stddev vwap) over multiple window sizes for streaming 
data. It uses West's algorithm for efficient updates and supports synthetic boundary 
entries to maintain consistent results.

Stats are computed based on data that exists inside the given window size, plus possibly
one (at most) synthetic entry: when old data shuffles out of the window, if there's no

view all matches for this distribution

Math-SZaru

1 match

lib/Math/SZaru.pm view on Meta::CPAN

The one unifying aspect of the implemented aggregators is that
they work with a single pass and with bounded memory overhead.
In CS terms, they should have near C<O(n)> compute complexity
and C<O(1)> or at least sub-linear memory overhead. The algorithms
may trade accuracy (hence I<*Estimator>) for this goal and are
intended for use with large and/or streaming data sets that
either do not fit in memory or whose total size is unknown.

The functionality is currently divided between three classes:
L<Math::SZaru::UniqueEstimator>, L<Math::SZaru::TopEstimator>,
and L<Math::SZaru::QuantileEstimator>. For details on those,

view all matches for this distribution

Math-ThinPlateSpline

1 match

src/linalg3d.cc view on Meta::CPAN

// Cross product
inline Vec TPS::cross(const Vec &a, const Vec &b) {
  return Vec( a.y*b.z - a.z*b.y, a.z*b.x - a.x*b.z, a.x*b.y - a.y*b.x );
}

// streaming
std::ostream&
TPS::operator<<(std::ostream& stream, Vec const& obj)
{
  obj.WriteTo(stream);
  return stream;

view all matches for this distribution

Memcached-libmemcached

2 results

src/libmemcached/libmemcached/memcached/protocol_binary.h view on Meta::CPAN

                 * server will transmit everything it contains.
                 *
                 * The first 8 bytes in the engine specific data contains
                 * the oldest entry (from epoc) you're interested in.
                 * Specifying a time in the future (for the server you are
                 * connecting to), will cause it to start streaming current
                 * changes.
                 */
#define TAP_CONNECT_FLAG_BACKFILL 0x01
                /**
                 * Dump will cause the server to send the data stored on the

view all matches for this distribution

Message-Passing-PSGI

2 results

lib/Plack/App/Message/Passing.pm view on Meta::CPAN

    do {
        $len = $input_fh->read(my $buf, 4096);
        $input .= $buf;
    } while ($len);
    $env->{'psgi.input'} = $input;
    delete $env->{'psgi.streaming'};
    $env->{'psgix.message.passing.clientid'} = refaddr($base_env);
    $env->{'psgix.message.passing.returnaddress'} = $self->return_address;
    $self->output_to->consume(encode_json $env);
    return sub {
        my $responder = shift;

view all matches for this distribution

Minima

1 match

t/51-stream.t view on Meta::CPAN

        field $app :param;
        field $route :param;
        method a {
            sub {
                my $w = shift->([ 200, [] ]);
                $w->write('streaming');
                $w->close;
            }
        };
    }
    EOF

t/51-stream.t view on Meta::CPAN

    my $app = Minima::App->new();
    my $test = Plack::Test->create(sub { $app->set_env(shift); $app->run });

    # Basic responses
    my $res = $test->request(GET '/');
    is( $res->content, "streaming", 'handles streaming properly' );

    $res = $test->request(HEAD '/');
    is( length($res->content), 0, 'returns empty body for HEAD (streaming)' );
}

chdir;

done_testing;

view all matches for this distribution

ModPerl2-Tools

1 match

Changes view on Meta::CPAN

0.10  Wed Jun 15 18:36:41 CEST 2011
      - clear subrequest's headers_in table before running it in fetch_url

0.09  Fri Jun 10 16:58:00 CEST 2011
      - streaming interface for fetch_url()

0.08  Mon Mar 14 20:14:39 CET 2011
      - next try to fix the close_fd bug. fileno(DIRHANDLE) does not work
        in Perl.

view all matches for this distribution

MogileFS-Client-Async

1 match

debian/changelog view on Meta::CPAN


 -- Dave Lambley <davel@state51.co.uk>  Tue, 26 Jul 2011 11:07:05 +0000

libmogilefs-client-async-perl (0.011-1) unstable; urgency=low

  * New streaming uploads into Mogile.

 -- Dave Lambley <davel@state51.co.uk>  Mon, 25 Jul 2011 12:38:37 +0100

libmogilefs-client-async-perl (0.010-1) unstable; urgency=low

view all matches for this distribution

MogileFS-Server

1 match

doc/checksums.txt view on Meta::CPAN


Ideally, mogstored checksum calculation is done by mogstored and only
the checksum (in $HASHTYPE=$HEXDIGEST format) is sent over the wire.

If mogstored is not available, the checksum is calculated on the tracker
by streaming the file with HTTP GET.

create_close (query worker)
---------------------------

New optional parameters:

view all matches for this distribution

Mojito

2 results


<h1><a class='u' href='#___top' title='click to go to top of document'
name="NAME"
>NAME <img alt='^' src='http://st.pimg.net/tucs/img/up.gif'></a></h1>

<p>HTML::Zoom - selector based streaming template engine</p>

<h1><a class='u' href='#___top' title='click to go to top of document'
name="SYNOPSIS"
>SYNOPSIS <img alt='^' src='http://st.pimg.net/tucs/img/up.gif'></a></h1>


<h1><a class='u' href='#___top' title='click to go to top of document'
name="DESCRIPTION"
>DESCRIPTION <img alt='^' src='http://st.pimg.net/tucs/img/up.gif'></a></h1>

<p>HTML::Zoom is a lazy, stream oriented, streaming capable, mostly functional, CSS selector based semantic templating engine for HTML and HTML-like document formats.</p>

<p>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:</p>

<h2><a class='u' href='#___top' title='click to go to top of document'
name="JQUERY_ENVY"


<p>... and by Weasel, I mean layout.</p>

<p>HTML::Zoom&#39;s filehandle object supports an additional event key, &#39;flush&#39;, 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.</p>

<p>This means that in an environment where streaming output is available, such as a number of the <a href="/perldoc?Plack" class="podlinkpod"
>Plack</a> 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&#39;re about to call a web service or a poten...

<p>This is currently exposed by the &#39;flush_before&#39; option to the collect filter, which incidentally also underlies the replace and repeat filters, so to indicate we want this behaviour to happen before a query is executed we can write somethi...

<pre class="prettyprint">  $zoom-&#62;select(&#39;.item&#39;)-&#62;repeat(sub {

>SEMANTIC DIDACTIC</a></h2>

<p>Some will argue that overloading CSS selectors to do data stuff is a terrible idea, and possibly even a step towards the &#34;Concrete Javascript&#34; pattern (which I abhor) or Smalltalk&#39;s Morphic (which I ignore, except for the part where it...

<p>To which I say, &#34;eh&#34;, &#34;meh&#34;, and possibly also &#34;feh&#34;. 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. <a...
>Template::Semantic</a> provides a similar idea to zoom except using XPath and XML::LibXML transforms rather than a lightweight streaming approach - maybe you&#39;d like that better. Or maybe you really did want <a href="/perldoc?Template" class="pod...
>Template Toolkit</a> after all. It is still damn good at what it does, after all.</p>

<p>So far, however, I&#39;ve found that for new sites the designers I&#39;m working with generally want to produce nice semantic HTML with classes that represent the nature of the data rather than the structure of the layout, so sharing them as a com...

<p>In the absence of any evidence that overloading CSS selectors has killed children or unexpectedly set fire to grandmothers - and given microformats have been around for a while there&#39;s been plenty of opportunity for octagenarian combustion - I...

name="GET_THEE_TO_A_SUMMARY!"
>GET THEE TO A SUMMARY!</a></h2>

<p>Erm. Well.</p>

<p>HTML::Zoom is a lazy, stream oriented, streaming capable, mostly functional, CSS selector based semantic templating engine for HTML and HTML-like document formats.</p>

<p>But I said that already. Although hopefully by now you have some idea what I meant when I said it. If you didn&#39;t have any idea the first time. I mean, I&#39;m not trying to call you stupid or anything. Just saying that maybe it wasn&#39;t tota...

<p>Er.</p>

view all matches for this distribution

MojoX-Twitter

5 results

examples/streaming.pl view on Meta::CPAN

    consumer_key    => 'z',
    consumer_secret => 'x',
    access_token        => '1-z',
    access_token_secret => 'x',
);
$twitter->streaming('https://userstream.twitter.com/1.1/user.json', { with => 'followings' }, sub {
    my ($tweet) = @_;
    say Dumper(\$tweet);
});

view all matches for this distribution

Mojolicious-Plugin-MountPSGI

4 results

lib/Mojolicious/Plugin/MountPSGI/Proxy.pm view on Meta::CPAN


  #TODO do something with $self->mode in delayed response
  # delayed (code reference) response
  my $responder = sub {
    my $plack_res = shift;
    my ($mojo_res, $streaming) = _psgi_res_to_mojo_res($plack_res);
    $c->tx->res($mojo_res);

    return $c->rendered unless $streaming;

    # streaming response, possibly chunked
    my $chunked = $mojo_res->content->is_chunked;
    my $write = $chunked ? sub { $c->write_chunk(@_) } : sub { $c->write(@_) };
    $write->(); # finalize header response
    return Plack::Util::inline_object(
      write => $write,

lib/Mojolicious/Plugin/MountPSGI/Proxy.pm view on Meta::CPAN

    'psgi.errors'       => *STDERR,
    'psgi.input'        => $input,
    '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,
  };
}

sub _psgi_res_to_mojo_res {

lib/Mojolicious/Plugin/MountPSGI/Proxy.pm view on Meta::CPAN


  my $headers = $mojo_res->headers;
  Plack::Util::header_iter $psgi_res->[1] => sub { $headers->header(@_) };
  $headers->remove('Content-Length'); # should be set by mojolicious later

  my $streaming = 0;
  if (@$psgi_res == 3) {
    my $asset = $mojo_res->content->asset;
    Plack::Util::foreach($psgi_res->[2], sub {$asset->add_chunk($_[0])});
  } else {
    $streaming = 1;
  }

  return ($mojo_res, $streaming);
}

1;

view all matches for this distribution

Mojolicious-Plugin-PlackMiddleware

2 results

lib/Mojolicious/Plugin/PlackMiddleware.pm view on Meta::CPAN

            'psgi.errors'       => *STDERR,
            'psgi.input'        => $body,
            '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,
        };
    }
    
    ### ---

view all matches for this distribution

Mojolicious-Plugin-RenderFile

2 results

lib/Mojolicious/Plugin/RenderFile.pm view on Meta::CPAN

        'cleanup'  => 1,                     # delete file after completed
    );

=head1 DESCRIPTION

L<Mojolicious::Plugin::RenderFile> is a L<Mojolicious> plugin that adds "render_file" helper. It does not read file in memory and just streaming it to a client.

=head1 HELPERS

=head2 C<render_file>

view all matches for this distribution

Mojolicious-Plugin-WebAPI

1 match

lib/Mojolicious/Plugin/WebAPI/Proxy.pm view on Meta::CPAN

        'psgi.errors'       => *STDERR,
        'psgi.input'        => $body,
        '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,
    };
}

sub _psgi_res_to_mojo_res {

view all matches for this distribution

Mojolicious

3 results

Changes view on Meta::CPAN

  - Added EXPERIMENTAL bytes_waiting and can_write methods to Mojo::IOLoop::Stream.
  - Added EXPERIMENTAL high_water_mark attribute to Mojo::IOLoop::Stream.
  - Updated bundled TLS certificate.
  - Improved Mojo::Base flags not to require a certain order.
  - Improved clone performance in Mojo::Headers by 100%.
  - Improved streaming response performance slightly.
  - Fixed a typo in the 425 status message in Mojo::Message::Response. (CandyAngel)
  - Fixed a missing deprecation warning in Mojo::Promise. (marcus)

8.17  2019-05-23
  - Fixed a bug in Mojo::UserAgent where the request timeout would not work for keep-alive requests. (ilmari)

view all matches for this distribution

MongoDB

1 match

lib/MongoDB/GridFSBucket.pm view on Meta::CPAN


filehandle-like: you get an object that you can read/write from similar to a filehandle.  You can even get a tied filehandle that you can hand off to other code that requires an actual Perl handle.

=item *

streaming: you provide a file handle to read from (upload) or print to (download) and data is streamed to (upload) or from (download) GridFS until EOF.

=back

=head2 Error handling

view all matches for this distribution

Monoceros

1 match

lib/Monoceros/Server.pm view on Meta::CPAN

                    'psgi.errors'       => *STDERR,
                    'psgi.url_scheme'   => 'http',
                    'psgi.run_once'     => Plack::Util::FALSE,
                    'psgi.multithread'  => Plack::Util::FALSE,
                    'psgi.multiprocess' => Plack::Util::TRUE,
                    'psgi.streaming'    => Plack::Util::TRUE,
                    'psgi.nonblocking'  => Plack::Util::FALSE,
                    'psgix.input.buffered' => Plack::Util::TRUE,
                    'psgix.io'          => $conn->{fh},
                    'psgix.harakiri'    => 1,
                    'X_MONOCEROS_WORKER_STATS' => $self->{stats_filename},

view all matches for this distribution

MsgPack-Raw

2 results