Result:
found more than 585 distributions - search limited to the first 2001 files matching your query ( run in 2.642 )


JSONL-Subset

 view release on metacpan or  search on metacpan

lib/JSONL/Subset.pm  view on Meta::CPAN


our @EXPORT_OK = qw(subset_jsonl);

sub subset_jsonl {
    my %args = @_;
    my ($infile, $outfile, $percent, $lines, $mode, $seed, $streaming) =
        @args{qw/infile outfile percent lines mode seed streaming/};

    die "infile, outfile, and percent or lines are required" unless $infile && $outfile && (defined $percent || defined $lines);
    die "cannot specify percent and lines, must choose one or the other" if (defined $percent && defined $lines);
    die "percent must be between 0 and 100" if (defined $percent && ($percent < 0 || $percent > 100));
    die "Invalid mode: $mode" unless $mode =~ /^(random|start|end)$/;

    $mode ||= 'random';

    if (!defined $streaming || $streaming == 0) {
        _subset_jsonl_inplace(
            infile  => $infile,
            outfile => $outfile,
            percent => $percent,
            lines   => $lines,
            mode    => $mode,
            seed    => $seed
        );
    } else {
        _subset_jsonl_streaming(
            infile  => $infile,
            outfile => $outfile,
            percent => $percent,
            lines   => $lines,
            mode    => $mode,

lib/JSONL/Subset.pm  view on Meta::CPAN

    $out->close;

    $in->close;
}

sub _subset_jsonl_streaming {
    my %args = @_;
    my ($infile, $outfile, $percent, $lines, $mode, $seed) =
        @args{qw/infile outfile percent lines mode seed/};

    my $in = IO::File->new($infile, "<:encoding(UTF-8)") or die "Can't read $infile: $!";

lib/JSONL/Subset.pm  view on Meta::CPAN

      infile    => "data.jsonl",
      outfile   => "subset.jsonl",
      percent   => 10,
      mode      => "random",  # or "start", "end"
      seed      => 42,
      streaming => 1
  );

=head1 DESCRIPTION

This module helps you extract a subset of lines from a JSONL file, for sampling or inspection.

lib/JSONL/Subset.pm  view on Meta::CPAN


=head2 seed

Only used with random, for reproducability. (optional)

=head2 streaming

If set, infile will be streamed line by line. This makes the process take less RAM, but more wall time.

Recommended for large JSONL files.

 view all matches for this distribution


Jabber-Connection

 view release on metacpan or  search on metacpan

README  view on Meta::CPAN


The package contains three modules:

- Jabber::Connection

  Handles connectivity, authentication, XML streaming and
  callbacks

- Jabber::NodeFactory

  Enables creation and manipulation of Jabber packets

 view all matches for this distribution


JavaScript-Duktape-XS

 view release on metacpan or  search on metacpan

duktape.c  view on Meta::CPAN

 *  and a simple copying one.
 *
 *  Decoding directly from the source string would be another lexing option.
 *  But the lookup window based approach has the advantage of hiding the
 *  source string and its encoding effectively which gives more flexibility
 *  going forward to e.g. support chunked streaming of source from flash.
 *
 *  Decodes UTF-8/CESU-8 leniently with support for code points from U+0000 to
 *  U+10FFFF, causing an error if the input is unparseable.  Leniency means:
 *
 *    * Unicode code point validation is intentionally not performed,

duktape.c  view on Meta::CPAN

 *      byte resulted in a code increase though.
 *
 *    * Is checking against maximum 0x10ffff really useful?  4-byte encoding
 *      imposes a certain limit anyway.
 *
 *    * Support chunked streaming of source code.  Can be implemented either
 *      by streaming chunks of bytes or chunks of codepoints.
 */

#if defined(DUK_USE_LEXER_SLIDING_WINDOW)
DUK_LOCAL void duk__fill_lexer_buffer(duk_lexer_ctx *lex_ctx, duk_small_uint_t start_offset_bytes) {
	duk_lexer_codepoint *cp, *cp_end;

 view all matches for this distribution


JavaScript-Duktape

 view release on metacpan or  search on metacpan

lib/JavaScript/Duktape/C/lib/duktape.c  view on Meta::CPAN

 *  and a simple copying one.
 *
 *  Decoding directly from the source string would be another lexing option.
 *  But the lookup window based approach has the advantage of hiding the
 *  source string and its encoding effectively which gives more flexibility
 *  going forward to e.g. support chunked streaming of source from flash.
 *
 *  Decodes UTF-8/CESU-8 leniently with support for code points from U+0000 to
 *  U+10FFFF, causing an error if the input is unparseable.  Leniency means:
 *
 *    * Unicode code point validation is intentionally not performed,

lib/JavaScript/Duktape/C/lib/duktape.c  view on Meta::CPAN

 *      byte resulted in a code increase though.
 *
 *    * Is checking against maximum 0x10ffff really useful?  4-byte encoding
 *      imposes a certain limit anyway.
 *
 *    * Support chunked streaming of source code.  Can be implemented either
 *      by streaming chunks of bytes or chunks of codepoints.
 */

#if defined(DUK_USE_LEXER_SLIDING_WINDOW)
DUK_LOCAL void duk__fill_lexer_buffer(duk_lexer_ctx *lex_ctx, duk_small_uint_t start_offset_bytes) {
	duk_lexer_codepoint *cp, *cp_end;

 view all matches for this distribution


JavaScript-Embedded

 view release on metacpan or  search on metacpan

lib/JavaScript/Embedded/C/lib/duktape.c  view on Meta::CPAN

 *  and a simple copying one.
 *
 *  Decoding directly from the source string would be another lexing option.
 *  But the lookup window based approach has the advantage of hiding the
 *  source string and its encoding effectively which gives more flexibility
 *  going forward to e.g. support chunked streaming of source from flash.
 *
 *  Decodes UTF-8/CESU-8 leniently with support for code points from U+0000 to
 *  U+10FFFF, causing an error if the input is unparseable.  Leniency means:
 *
 *    * Unicode code point validation is intentionally not performed,

lib/JavaScript/Embedded/C/lib/duktape.c  view on Meta::CPAN

 *      byte resulted in a code increase though.
 *
 *    * Is checking against maximum 0x10ffff really useful?  4-byte encoding
 *      imposes a certain limit anyway.
 *
 *    * Support chunked streaming of source code.  Can be implemented either
 *      by streaming chunks of bytes or chunks of codepoints.
 */

#if defined(DUK_USE_LEXER_SLIDING_WINDOW)
DUK_LOCAL void duk__fill_lexer_buffer(duk_lexer_ctx *lex_ctx, duk_small_uint_t start_offset_bytes) {
	duk_lexer_codepoint *cp, *cp_end;

 view all matches for this distribution


Jifty

 view release on metacpan or  search on metacpan

lib/Jifty/Handler.pm  view on Meta::CPAN

    }

    $static->add( Plack::App::File->new
            ( root => Jifty->config->framework('Web')->{DefaultStaticRoot} )->to_app );

    # the buffering and unsetting of psgi.streaming is to vivify the
    # responded res from the $static cascade app.
    builder {
        enable 'Plack::Middleware::ConditionalGET';
        enable
            sub { my $app = shift;
                  sub { my $env = shift;
                        $env->{'psgi.streaming'} = 0;
                        my $res = $app->($env);
                        # skip streamy response
                        return $res unless ref($res) eq 'ARRAY' && $res->[2];
                        my $h = Plack::Util::headers($res->[1]);;
                        $h->set( 'Cache-Control' => 'max-age=31536000, public' );

 view all matches for this distribution


Kamaitachi

 view release on metacpan or  search on metacpan

lib/Kamaitachi/Service/StreamAudienceCounter.pm  view on Meta::CPAN


=encoding utf8

=head1 NAME

Kamaitachi::Service::StreamAudienceCounter - service role to count and broadcast streaming audience

=head1 SYNOPSIS

=head1 DESCRIPTION

 view all matches for this distribution


Kelp

 view release on metacpan or  search on metacpan

lib/Kelp/Response.pm  view on Meta::CPAN

=head2 partial

Sets partial response. If this attribute is set to a true value, it will cause
C<finalize> to return the HTTP status code and headers, but not the body. This is
convenient if you intend to stream your content. In the following example, we
set C<partial> to 1 and use C<finalize> to get a C<writer> object for streaming.

    sub stream {
        my $self = shift;
        return sub {
            my $responder = shift;

 view all matches for this distribution


KiokuDB

 view release on metacpan or  search on metacpan

lib/KiokuDB/Backend/Serialize/Storable.pm  view on Meta::CPAN

    with qw(KiokuDB::Backend::Serialize::Storable;

=head1 DESCRIPTION

This role provides L<Storable> based serialization of L<KiokuDB::Entry> objects
for a backend, with streaming capabilities.

L<KiokuDB::Backend::Serialize::Delegate> is preferred to using this directly.

=head1 METHODS

 view all matches for this distribution


Kubernetes-REST

 view release on metacpan or  search on metacpan

lib/Kubernetes/REST.pm  view on Meta::CPAN

# ============================================================================
# PUBLIC BUILDING BLOCKS FOR ASYNC WRAPPERS
#
# These methods expose the internal request/response pipeline as a stable API
# for async wrappers (e.g. Net::Async::Kubernetes) that need to build requests,
# process responses, and handle streaming without going through the sync
# convenience methods (list, get, watch, log, port_forward, exec, attach, etc.).
# ============================================================================

sub build_path {
    my ($self, @args) = @_;

lib/Kubernetes/REST.pm  view on Meta::CPAN

            $got_410 = 1 if $result->{error_code} == 410;
            $on_event->($result->{event});
        }
    };

    my $response = $self->io->call_streaming($req, $data_callback);

    $self->_check_response($response, "watch $short_class");

    croak "Watch expired (410 Gone): resourceVersion too old, re-list to get a fresh resourceVersion"
        if $got_410;

lib/Kubernetes/REST.pm  view on Meta::CPAN

            for my $event ($self->_process_log_chunk(\$buffer, $chunk)) {
                $on_line->($event);
            }
        };

        my $response = $self->io->call_streaming($req, $data_callback);
        $self->_check_response($response, "log $short_class");

        # Process any remaining data in buffer (last line without trailing newline)
        if (length $buffer) {
            $on_line->(Kubernetes::REST::LogEvent->new(line => $buffer));

lib/Kubernetes/REST.pm  view on Meta::CPAN


    my @results = $api->process_watch_chunk($class, \$buffer, $chunk);

Process a chunk of NDJSON watch data. Appends the chunk to the buffer, extracts complete lines, and returns a list of hashrefs with C<event> (L<Kubernetes::REST::WatchEvent>), C<resourceVersion>, C<is_error>, and C<error_code>.

This is a public API for async wrappers that handle streaming watch responses through their own event loop.

=head2 process_log_chunk

    my @events = $api->process_log_chunk(\$buffer, $chunk);

Process a chunk of plain-text log data. Appends the chunk to the buffer, extracts complete lines, and returns a list of L<Kubernetes::REST::LogEvent> objects.

This is a public API for async wrappers that handle streaming log responses through their own event loop.

=head2 list

    my $list = $api->list('Pod', namespace => 'default');
    my $list = $api->list('Namespace', labelSelector => 'app=web');

lib/Kubernetes/REST.pm  view on Meta::CPAN


B<One-shot> (without C<on_line>): Returns the full log text as a string.

B<Streaming> (with C<on_line>): Calls the callback for each log line with a L<Kubernetes::REST::LogEvent> object. Blocks until the stream ends (or the server closes the connection).

The streaming mode is designed for event-based systems like L<IO::Async> — see L<Net::Async::Kubernetes> for async integration.

=head2 port_forward

    my $session = $api->port_forward('Pod', 'my-pod',
        namespace => 'default',

lib/Kubernetes/REST.pm  view on Meta::CPAN


=head2 io

Optional. HTTP backend for making requests. Must consume the
L<Kubernetes::REST::Role::IO> role (i.e. implement C<call($req)> and
C<call_streaming($req, $callback)>; optional C<call_duplex($req, %callbacks)> for
full-duplex subresources such as pod port-forward). Defaults to L<Kubernetes::REST::LWPIO>
(L<LWP::UserAgent>), which supports L<LWP::ConsoleLogger> for HTTP debugging.

To use the lighter L<HTTP::Tiny> backend instead:

lib/Kubernetes/REST.pm  view on Meta::CPAN

    1. prepare_request()    - builds HTTPRequest (method, url, headers, body)
    2. io->call()           - executes request (pluggable backend)
    3. check_response()     - validates HTTP status
    4. inflate_object/list  - decodes JSON + inflates IO::K8s objects

For watch, step 2 uses C<io-E<gt>call_streaming()> and step 4 uses
C<process_watch_chunk()> which parses NDJSON and inflates each event.

For log, step 2 uses C<io-E<gt>call_streaming()> and step 4 uses
C<process_log_chunk()> which parses plain-text lines into L<Kubernetes::REST::LogEvent> objects.

To implement a custom IO backend, consume L<Kubernetes::REST::Role::IO>
and implement C<call($req)> and C<call_streaming($req, $callback)>.
See L<Kubernetes::REST::LWPIO> and L<Kubernetes::REST::HTTPTinyIO> for
reference implementations.

=head1 SEE ALSO

 view all matches for this distribution


LTSV-LINQ

 view release on metacpan or  search on metacpan

lib/LTSV/LINQ.pm  view on Meta::CPAN

=over 4

=item * B<One record per line>

A complete record is always a single newline-terminated line. This makes
streaming processing trivial: read a line, parse it, process it, discard it.
There is no multi-line quoting problem, no block parser required.

=item * B<Tab as field delimiter>

Fields are separated by a single horizontal tab character (C<0x09>).

lib/LTSV/LINQ.pm  view on Meta::CPAN

does not break parsers that do not know about it.

=item * B<Streaming-friendly>

Because each record is one line, LTSV files can be processed with line-by-line
streaming. Memory usage is proportional to the longest single record, not
the total file size. This is why C<FromLTSV> in this module uses a lazy
iterator rather than loading the whole file.

=item * B<Grep- and awk-friendly>

lib/LTSV/LINQ.pm  view on Meta::CPAN

=item * B<Wide adoption in server logging>

LTSV originated in the Japanese web industry as a structured log format for
HTTP access logs. Many web servers (Apache, Nginx) and log aggregation tools
support LTSV output or parsing. The format is particularly popular for
application and infrastructure logging where grep-ability and streaming
analysis matter.

=back

For the formal LTSV specification, see L<http://ltsv.org/>.

lib/LTSV/LINQ.pm  view on Meta::CPAN

  # Faster - limit before sorting (if possible)
  ->Where(status => '500')->OrderBy(...)->Take(10)

=item B<Q: How do I process files larger than memory?>

A: Use ForEach or streaming terminal operations:

  # Process 100GB file with 1KB memory
  my $error_count = 0;
  LTSV::LINQ->FromLTSV("100gb.log")
      ->Where(sub { $_[0]{level} eq 'ERROR' })

 view all matches for this distribution


LWP-MediaTypes

 view release on metacpan or  search on metacpan

lib/LWP/media.types  view on Meta::CPAN

application/vnd.oasis.opendocument.text-master		odm
application/vnd.oasis.opendocument.text-template	ott
application/vnd.oasis.opendocument.text-web		oth
# application/vnd.obn
# 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 all matches for this distribution


LaBrea-Tarpit

 view release on metacpan or  search on metacpan

Report/examples/localTrojans.pl  view on Meta::CPAN

644	tcp/udp	dwr	dwr
645	tcp/udp	pssc	PSSC
646	tcp/udp	ldp	LDP
647	tcp/udp	dhcp-failover	DHCP Failover
648	tcp/udp	rrp	Registry Registrar Protocol (RRP)
649	tcp/udp	cadview-3d	Cadview-3d - streaming 3d models over the internet
650	tcp/udp	obex	OBEX
651	tcp/udp	ieee-mms	IEEE MMS
652	tcp/udp	hello-port	HELLO_PORT
653	tcp/udp	repscmd	RepCmd
654	tcp/udp	aodv	AODV

Report/examples/localTrojans.pl  view on Meta::CPAN

1750	tcp/udp	sslp	Simple Socket Library's PortMaster
1751	tcp/udp	swiftnet	SwiftNet
1752	tcp/udp	lofr-lm	Leap of Faith Research License Manager
1753	tcp/udp	#	Unassigned
1754	tcp/udp	oracle-em2	oracle-em2
1755	tcp/udp	ms-streaming	ms-streaming
1756	tcp/udp	capfast-lmd	capfast-lmd
1757	tcp/udp	cnhrp	cnhrp
1758	tcp/udp	tftp-mcast	tftp-mcast
1759	tcp/udp	spss-lm	SPSS License Manager
1760	tcp/udp	www-ldap-gw	www-ldap-gw

 view all matches for this distribution


Lab-Measurement

 view release on metacpan or  search on metacpan

lib/Lab/Moose/Instrument/ZI_HDAWG.pm  view on Meta::CPAN

Type: Double(D)
Unit: Mbit/s

 get_stats_cmdstream_bandwidth()

Command streaming bandwidth usage on the physical network connection between device and
data server.

=head3 /DEV/STATS/CMDSTREAM/BYTESRECEIVED 
Properties: Read 
Type: Integer (64 bit)(I)

lib/Lab/Moose/Instrument/ZI_HDAWG.pm  view on Meta::CPAN

Type: Double(D)
Unit: Mbit/s

 get_stats_datastream_bandwidth()

Data streaming bandwidth usage on the physical network connection between device and data
server.

=head3 /DEV/STATS/DATASTREAM/BYTESRECEIVED 
Properties: Read 
Type: Integer (64 bit)(I)

lib/Lab/Moose/Instrument/ZI_HDAWG.pm  view on Meta::CPAN

Unit: None

 set_triggers_streams_enable(stream => $stream, value => $value)
 get_triggers_streams_enable(stream => $stream)

Enables trigger streaming.

=head3 /DEV/TRIGGERS/STREAMS/n/HOLDOFFTIME 
Properties: Read Write Setting 
Type: Double(D)
Unit: s

 view all matches for this distribution


Langertha-Knarr

 view release on metacpan or  search on metacpan

lib/Langertha/Knarr.pm  view on Meta::CPAN

ACP's C</runs>, and AG-UI's C</awp> simultaneously on every listening
port. The same handler implementation drives all of them.

Knarr 1.000 is built on L<IO::Async> and L<Net::Async::HTTP::Server>
with native L<Future::AsyncAwait> integration into Langertha engines,
so streaming works end-to-end token-by-token without any thread or
event-loop bridges.

=head1 ARCHITECTURE

Three pluggable layers:

lib/Langertha/Knarr.pm  view on Meta::CPAN

compose freely.

=item B<Transport>

Default is L<Net::Async::HTTP::Server> with chunked SSE / NDJSON
streaming on one or more listen sockets. For Plack deployments,
L<Langertha::Knarr::PSGI> wraps the same Knarr instance into a PSGI
app (buffered — see its docs for the streaming caveat).

=back

=head2 handler

 view all matches for this distribution


Langertha-Skeid

 view release on metacpan or  search on metacpan

lib/Langertha/Skeid/Proxy.pm  view on Meta::CPAN

  }

  if ($body->{stream}) {
    $c->render(json => {
      error => {
        message => 'Anthropic streaming is not implemented in Skeid proxy yet',
        type    => 'not_supported_error',
      }
    }, status => 501);
    return;
  }

lib/Langertha/Skeid/Proxy.pm  view on Meta::CPAN

    $c->render(json => { error => 'Invalid JSON body' }, status => 400);
    return;
  }

  if ($body->{stream}) {
    $c->render(json => { error => 'Ollama streaming is not implemented in Skeid proxy yet' }, status => 501);
    return;
  }

  my $openai_body = {
    model => ($body->{model} // ''),

 view all matches for this distribution


Langertha

 view release on metacpan or  search on metacpan

ex/async_await.pl  view on Meta::CPAN

  say "Response: $response\n";
  return $response;
}

# Example 2: Streaming with real-time callback
async sub streaming_example {
  my ($api_key) = @_;

  say "=== Example 2: Streaming Chat with Real-time Callback ===\n";

  my $engine = Langertha::Engine::Anthropic->new(

ex/async_await.pl  view on Meta::CPAN

  say "Langertha Future::AsyncAwait Examples\n";
  say "=" x 50 . "\n";

  # Run examples (they return Futures, so we need to ->get them)
  simple_example($api_key)->get;
  streaming_example($api_key)->get;
  concurrent_example($api_key)->get;

  # Error handling example doesn't need real API key
  error_handling_example($api_key)->get;

 view all matches for this distribution


Language-FormulaEngine

 view release on metacpan or  search on metacpan

lib/Language/FormulaEngine/Parser.pm  view on Meta::CPAN

=head1 DESCRIPTION

This class scans tokens from an input string and builds a parse tree.  In compiler terminology,
it is both a Scanner and Parser.  It performs a top-down recursive descent parse, because this
is easy and gives good error messages.  It only parses strings, but leaves room for subclasses
to implement streaming.  By default, the parser simply applies a Grammar to the input, without
checking whether the functions or variables exist, but can be subclassed to do more detailed
analysis during the parse.

The generated parse tree is made up of Function nodes (each infix operator is converted to a
named function) and each Function node may contain Symbols, Strings, Numbers, and other

 view all matches for this distribution


Language-Zcode

 view release on metacpan or  search on metacpan

DIARY.txt  view on Meta::CPAN

----------------------------- November 20, 2003 --------------------------------
Looks like stuff in the upper window doesn't get written to stream 2, but DOES
get written to stream 3.

----------------------------- November 25, 2003 --------------------------------
Thinking about streaming

----------------------------- November 26, 2003 --------------------------------
Wrote lots of notes on streaming plans. I think I have a workable system.
Text is turned into PP::Text objects which are blessed scalarrefs; the
subclasses determine whether the text was input or output, etc.

PP::Output tries to write to every stream (but returns immediately if it
wrote to stream 3). Each OutputStream tests itself to see whether it's

 view all matches for this distribution


Lemonldap-NG-Handler

 view release on metacpan or  search on metacpan

lib/Lemonldap/NG/Handler/ApacheMP2/Request.pm  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,
        'psgix.cleanup'          => Plack::Util::TRUE,
        'psgix.cleanup.handlers' => [],
        'psgi.r'                 => $r,

 view all matches for this distribution


Lemonldap-NG-Portal

 view release on metacpan or  search on metacpan

t/44-CertificateResetByMail-Demo.t  view on Meta::CPAN

                        'Plack::Request::Upload'
                    )
                },
                'Hash::MultiValue'
            ),
            'psgi.streaming'     => 1,
            'plack.request.body' => bless( {
                    'skin'  => 'bootstrap',
                    'url'   => '',
                    'token' => $inputs{'token'}
                },

t/44-CertificateResetByMail-Demo.t  view on Meta::CPAN

                        'Plack::Request::Upload'
                    )
                },
                'Hash::MultiValue'
            ),
            'psgi.streaming'     => 1,
            'plack.request.body' => bless( {
                    'skin'  => 'bootstrap',
                    'url'   => '',
                    'token' => $inputs{'token'}
                },

 view all matches for this distribution


Lingua-Concordance

 view release on metacpan or  search on metacpan

etc/walden.txt  view on Meta::CPAN

with an excess of these, or of Fuel, that is, with an external heat
greater than our own internal, may not cookery properly be said to
begin? Darwin, the naturalist, says of the inhabitants of Tierra del
Fuego, that while his own party, who were well clothed and sitting
close to a fire, were far from too warm, these naked savages, who were
farther off, were observed, to his great surprise, "to be streaming
with perspiration at undergoing such a roasting." So, we are told, the
New Hollander goes naked with impunity, while the European shivers
in his clothes. Is it impossible to combine the hardiness of these
savages with the intellectualness of the civilized man? According to
Liebig, man's body is a stove, and food the fuel which keeps up the

etc/walden.txt  view on Meta::CPAN


  When I meet the engine with its train of cars moving off with
planetary motion- or, rather, like a comet, for the beholder knows not
if with that velocity and with that direction it will ever revisit
this system, since its orbit does not look like a returning curve-
with its steam cloud like a banner streaming behind in golden and
silver wreaths, like many a downy cloud which I have seen, high in the
heavens, unfolding its masses to the light- as if this traveling
demigod, this cloud- compeller, would ere long take the sunset sky for
the livery of his train; when I hear the iron horse make the bills
echo with his snort like thunder, shaking the earth with his feet, and

 view all matches for this distribution


Lingua-EN-Bigram

 view release on metacpan or  search on metacpan

etc/walden.txt  view on Meta::CPAN

with an excess of these, or of Fuel, that is, with an external heat
greater than our own internal, may not cookery properly be said to
begin? Darwin, the naturalist, says of the inhabitants of Tierra del
Fuego, that while his own party, who were well clothed and sitting
close to a fire, were far from too warm, these naked savages, who were
farther off, were observed, to his great surprise, "to be streaming
with perspiration at undergoing such a roasting." So, we are told, the
New Hollander goes naked with impunity, while the European shivers
in his clothes. Is it impossible to combine the hardiness of these
savages with the intellectualness of the civilized man? According to
Liebig, man's body is a stove, and food the fuel which keeps up the

etc/walden.txt  view on Meta::CPAN


  When I meet the engine with its train of cars moving off with
planetary motion- or, rather, like a comet, for the beholder knows not
if with that velocity and with that direction it will ever revisit
this system, since its orbit does not look like a returning curve-
with its steam cloud like a banner streaming behind in golden and
silver wreaths, like many a downy cloud which I have seen, high in the
heavens, unfolding its masses to the light- as if this traveling
demigod, this cloud- compeller, would ere long take the sunset sky for
the livery of his train; when I hear the iron horse make the bills
echo with his snort like thunder, shaking the earth with his feet, and

 view all matches for this distribution


Lingua-EN-Ngram

 view release on metacpan or  search on metacpan

etc/walden.txt  view on Meta::CPAN

with an excess of these, or of Fuel, that is, with an external heat
greater than our own internal, may not cookery properly be said to
begin? Darwin, the naturalist, says of the inhabitants of Tierra del
Fuego, that while his own party, who were well clothed and sitting
close to a fire, were far from too warm, these naked savages, who were
farther off, were observed, to his great surprise, "to be streaming
with perspiration at undergoing such a roasting." So, we are told, the
New Hollander goes naked with impunity, while the European shivers
in his clothes. Is it impossible to combine the hardiness of these
savages with the intellectualness of the civilized man? According to
Liebig, man's body is a stove, and food the fuel which keeps up the

etc/walden.txt  view on Meta::CPAN


  When I meet the engine with its train of cars moving off with
planetary motion- or, rather, like a comet, for the beholder knows not
if with that velocity and with that direction it will ever revisit
this system, since its orbit does not look like a returning curve-
with its steam cloud like a banner streaming behind in golden and
silver wreaths, like many a downy cloud which I have seen, high in the
heavens, unfolding its masses to the light- as if this traveling
demigod, this cloud- compeller, would ere long take the sunset sky for
the livery of his train; when I hear the iron horse make the bills
echo with his snort like thunder, shaking the earth with his feet, and

 view all matches for this distribution


Lingua-EN-Opinion

 view release on metacpan or  search on metacpan

lib/Lingua/EN/Opinion/Emotion.pm  view on Meta::CPAN

        stray => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 1, positive => 0, sadness => 0, surprise => 0, trust => 0 },
        streak => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 0, positive => 0, sadness => 0, surprise => 0, trust => 0 },
        streaked => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 0, positive => 0, sadness => 0, surprise => 0, trust => 0 },
        stream => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 0, positive => 0, sadness => 0, surprise => 0, trust => 0 },
        streamer => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 0, positive => 0, sadness => 0, surprise => 0, trust => 0 },
        streaming => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 0, positive => 0, sadness => 0, surprise => 0, trust => 0 },
        street => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 0, positive => 0, sadness => 0, surprise => 0, trust => 0 },
        strength => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 0, positive => 1, sadness => 0, surprise => 0, trust => 1 },
        strengthen => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 0, positive => 1, sadness => 0, surprise => 0, trust => 0 },
        strengthening => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 1, negative => 0, positive => 1, sadness => 0, surprise => 0, trust => 1 },
        strenuous => { anger => 0, anticipation => 0, disgust => 0, fear => 0, joy => 0, negative => 0, positive => 0, sadness => 0, surprise => 0, trust => 0 },

 view all matches for this distribution


Lingua-EN-SENNA

 view release on metacpan or  search on metacpan

lib/Lingua/EN/SENNA/third-party/senna/hash/words.lst  view on Meta::CPAN

mainspring
mainstage
mainstay
mainstays
mainstream
mainstreaming
maintain
maintainability
maintainance
maintained
maintainer

lib/Lingua/EN/SENNA/third-party/senna/hash/words.lst  view on Meta::CPAN

streaky
stream
streamed
streamer
streamers
streaming
streamline
streamlined
streamliner
streamlines
streamlining

 view all matches for this distribution


Lingua-EN-Segment

 view release on metacpan or  search on metacpan

share/count_1w.txt  view on Meta::CPAN

isolated	9421703
calgary	9415992
interim	9415083
assisted	9413705
divine	9413498
streaming	9413174
approve	9410993
chose	9409845
compound	9406648
intensity	9405746
technological	9404975

share/count_1w.txt  view on Meta::CPAN

gulch	647573
striping	647561
excavating	647551
recoveries	647449
mrsa	647429
mainstreaming	647414
awt	647406
irrevocable	647399
wieder	647390
hola	647293
hoody	647288

share/count_1w.txt  view on Meta::CPAN

handicaped	20442
forwood	20442
easytel	20442
cobr	20442
bwbar	20442
slipstreaming	20441
resourceindex	20441
osem	20441
muv	20441
mosce	20441
metservice	20441

share/count_1w.txt  view on Meta::CPAN

iprodione	19374
instrumenta	19374
elapsing	19374
clanger	19374
ardwick	19374
unitedstreaming	19373
transthyretin	19373
shoponline	19373
mathopd	19373
lawindexpro	19373
warson	19372

share/count_1w.txt  view on Meta::CPAN

kathlene	15009
fanello	15009
cambrensis	15009
woodleaf	15008
unimolecular	15008
streamingcontext	15008
nzax	15008
lightsalmon	15008
jrx	15008
heinlin	15008
gluonic	15008

share/count_1w.txt  view on Meta::CPAN

basketballtickets	12775
ashkra	12775
altarvista	12775
aissa	12775
tuxpan	12774
streamingvideos	12774
sbq	12774
sadis	12774
relativization	12774
realtion	12774
phryne	12774

 view all matches for this distribution


Lingua-EN-Tagger

 view release on metacpan or  search on metacpan

Tagger/words.yml  view on Meta::CPAN

streaked: { vbd: 1 }
stream-of-consciousness: { nn: 1 }
stream: { nn: 12 }
Stream: { nnp: 1 }
streamed: { vbd: 3 }
streaming: { vbg: 1 }
streamline: { vb: 9 }
streamlined: { jj: 3, vbd: 1 }
streamlining: { nn: 4, vbg: 9 }
streams: { nns: 1 }
Streep: { nnp: 1 }

 view all matches for this distribution


Lingua-Identify-CLD

 view release on metacpan or  search on metacpan

cld-src/base/logging.h  view on Meta::CPAN

  }
#endif

// We use the preprocessor's merging operator, "##", so that, e.g.,
// LOG(INFO) becomes the token GOOGLE_LOG_INFO.  There's some funny
// subtle difference between ostream member streaming functions (e.g.,
// ostream::operator<<(int) and ostream non-member streaming functions
// (e.g., ::operator<<(ostream&, string&): it turns out that it's
// impossible to stream something like a string directly to an unnamed
// ostream. We employ a neat hack by calling the stream() member
// function of LogMessage which seems to avoid the problem.
#define LOG(severity) COMPACT_GOOGLE_LOG_ ## severity.stream()

cld-src/base/logging.h  view on Meta::CPAN

#define assert(x) DLOG_ASSERT(x)

//
// This class more or less represents a particular log message.  You
// create an instance of LogMessage and then stream stuff to it.
// When you finish streaming to it, ~LogMessage is called and the
// full message gets streamed to the appropriate destination.
//
// You shouldn't actually use LogMessage's constructor to log things,
// though.  You should use the LOG() macro (and variants thereof)
// above.

cld-src/base/logging.h  view on Meta::CPAN

  // called by the destructor, it may also be called from elsewhere if
  // needed.  Only the first call is actioned; any later ones are ignored.
  void Flush();

  // An arbitrary limit on the length of a single log message.  This
  // is so that streaming can be done more efficiently.
  static const size_t kMaxLogMessageLen;

  // Theses should not be called directly outside of logging.*,
  // only passed as SendMethod arguments to other LogMessage methods:
  void SendToLog();  // Actually dispatch to the logs

 view all matches for this distribution


Lingua-Lexicon-IDP

 view release on metacpan or  search on metacpan

lib/Lingua/Lexicon/IDP/Data/en_it.txt  view on Meta::CPAN

star	stella[Noun]
straw	paglia[Noun]
strawberries	fragole[Noun]
strawberry	fragola[Noun]
stream	ruscello[Noun]
streaming	che scorre
street	strada[Noun]
streets	strade[Noun]
strength	forza[Noun]
strengthen	rinforzare, rafforzare[Verb]
strengthened	rinforzato[Adjective]

 view all matches for this distribution


( run in 2.642 seconds using v1.01-cache-2.11-cpan-600a1bdf6e4 )