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
view release on metacpan or search on metacpan
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
view release on metacpan or search on metacpan
* 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,
* 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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
view release on metacpan or search on metacpan
----------------------------- 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
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
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
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
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
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
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
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
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
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
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
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