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
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Perinci/CmdLine/dux.pm view on Meta::CPAN
# set `out` argument for the dux function
my $streamo = $r->{meta}{"x.app.dux.is_stream_output"} //
$r->{meta}{"x.dux.is_stream_output"}; # backward-compat, will be removed someday
my $fmt = $r->{format} // 'text';
if (!defined($streamo)) {
# turn on streaming if format is simple text
my $iactive;
if (-t STDOUT) {
$iactive = 1;
} elsif ($ENV{INTERACTIVE}) {
$iactive = 1;
lib/Perinci/CmdLine/dux.pm view on Meta::CPAN
}
sub hook_format_result {
my ($self, $r) = @_;
# turn off streaming if response is an error response
if ($r->{res}[0] !~ /\A2/) {
$r->{is_stream_output} = 0;
}
return '' if $r->{is_stream_output};
view all matches for this distribution
view release on metacpan or search on metacpan
script/freqtable view on Meta::CPAN
1 two
1 four
=head2 Running table (`--output-every` option)
If you have streaming input, you can instruct `freqtable` to print the result
periodically after a number of input lines/words/characters/bytes. You can also
instruct to clear the terminal screen before every output
(`--clear-before-output`).
% perl -MArray::Sample::WeightedRandom=sample_weighted_random_with_replacement \
view all matches for this distribution
view release on metacpan or search on metacpan
- Adjust to App::wordlist 0.270 (option 'random' re-added).
0.005 2020-05-18 Released-By: PERLANCAR; Urgency: medium
- Update to App::wordlist 0.268+ (streaming result).
0.004 2018-01-09 Released-By: PERLANCAR
- Update to App::genpw 0.002.
view all matches for this distribution
view release on metacpan or search on metacpan
lib/FlashVideo/RTMPDownloader.pm view on Meta::CPAN
my($r_fh, $w_fh); # So Perl doesn't close them behind our back..
if ($rtmp_data->{live} && $self->action eq 'play') {
# Playing live stream, we pipe this straight to the player, rather than
# saving on disk.
# XXX: The use of /dev/fd could go away now rtmpdump supports streaming to
# STDOUT.
pipe($r_fh, $w_fh);
my $pid = fork;
view all matches for this distribution
view release on metacpan or search on metacpan
lib/App/htmlcat.pm view on Meta::CPAN
my $self = shift;
return sub {
my $env = shift;
$env->{'psgi.streaming'} or die 'psgi.streaming not supported';
if ($env->{PATH_INFO} eq '/stream') {
return sub {
my $respond = shift;
view all matches for this distribution
view release on metacpan or search on metacpan
lib/App/Phoebe/Chat.pm view on Meta::CPAN
encode_utf8
"This server supports a Gemini-based chat. "
. "If you don't have a dedicated client, you can use two windows of a regular Gemini client. "
. "Visit the following two URLs. "
. "The first one allows you âlistenâ to the channel and the second one allows you to âsayâ things. "
. "The connection to the âlistenâ channel needs a streaming client. "
. "Use a client certificate with the same common name for both connections.\n");
$stream->write("=> $url/listen\r\n");
$stream->write("=> $url/say\r\n");
}
view all matches for this distribution
view release on metacpan or search on metacpan
You can run rmcd on one computer and remotely control it on another,
fully transparent. It only cares for the presence of the named pipe.
You can also setup mplayer to stream the content to you, creating a
solution similar to MPD and their builti-in httpd streaming (except MPD
does not support video streaming).
rmcd features a built-in, user configurable, web radio management
system, functionality for copying the current track to your portable mp3
player or wherever you prefer, favorizing of tracks and loading of the
same, now playing information for both local files and streams, along
view all matches for this distribution
view release on metacpan or search on metacpan
0.006 2023-02-12 Released-By: PERLANCAR; Urgency: medium
- Add action 'stream_as_csv'
- Handle table with infinite rows by streaming as CSV as default action.
0.005 2022-10-18 Released-By: PERLANCAR; Urgency: low
- No functional changes.
view all matches for this distribution
view release on metacpan or search on metacpan
- Fix lookup of "Property:P_"
0.3.2 2015-10-16 14:14:24 CEST
- Fix zero-result-bug in lookup mode
- Support limit in lookup mode
- Enable streaming output of simple JSON format
0.3.1 2015-10-16 11:13:18 CEST
- Simplify lookup by passing ids as command line arguments
- Implement proper exit codes and option to ignore errors
view all matches for this distribution
view release on metacpan or search on metacpan
lib/App/wordlist/blossom.pm view on Meta::CPAN
=item * B<random> => I<bool>
Pick random words.
If set to true, then streaming will be turned off. All words will be gathered
first, then words will be chosen randomly from the gathered list.
=item * B<wordlist_bundles> => I<array[str]>
Select one or more wordlist bundle (Acme::CPANModules::WordListBundle::*) modules.
view all matches for this distribution
view release on metacpan or search on metacpan
lib/App/wordlist/wordle.pm view on Meta::CPAN
=item * B<random> => I<bool>
Pick random words.
If set to true, then streaming will be turned off. All words will be gathered
first, then words will be chosen randomly from the gathered list.
=item * B<wordlist_bundles> => I<array[str]>
Select one or more wordlist bundle (Acme::CPANModules::WordListBundle::*) modules.
view all matches for this distribution
view release on metacpan or search on metacpan
lib/App/wordlist.pm view on Meta::CPAN
},
random => {
summary => 'Pick random words',
description => <<'_',
If set to true, then streaming will be turned off. All words will be gathered
first, then words will be chosen randomly from the gathered list.
_
schema => 'bool*',
cmdline_aliases => {r=>{}},
lib/App/wordlist.pm view on Meta::CPAN
=item * B<random> => I<bool>
Pick random words.
If set to true, then streaming will be turned off. All words will be gathered
first, then words will be chosen randomly from the gathered list.
=item * B<wordlist_bundles> => I<array[str]>
Select one or more wordlist bundle (Acme::CPANModules::WordListBundle::*) modules.
view all matches for this distribution
view release on metacpan or search on metacpan
Tue Apr 30 14:19:52 2024 +0100
882745aa42cff181597a451a8f137d095703cbfb
4.004 30 April 2024
* #20 weak encryption + streaming does not set local CRC value to zero
Tue Apr 30 10:41:48 2024 +0100
7952c1c46282ebd54f80736cd3da659c0d430f3e
* typo - 0027 test directory should be 0027-bsdtar
Tue Apr 30 10:18:15 2024 +0100
view all matches for this distribution
view release on metacpan or search on metacpan
unzip-6.0/unzip.c view on Meta::CPAN
" Currently split archives are not readable by unzip. A workaround is",
" to use zip to convert the split archive to a single-file archive and",
" use unzip on that. See the manual page for Zip 3.0 or later.",
"",
"Streaming (piping into unzip):",
" Currently unzip does not support streaming. The funzip utility can be",
" used to process the first entry in a stream.",
" cat archive | funzip",
"",
"Testing archives:",
" -t test contents of archive",
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Archive/Zip/SimpleUnzip.pm view on Meta::CPAN
*$inner->{NewStream} = 0 ;
*$inner->{EndStream} = 0 ;
*$inner->{TotalInflatedBytesRead} = 0;
*$inner->{Info}{TrailerLength} = 0;
# disable streaming if present & set sizes from central dir
# TODO - this will only allow a single file to be read at a time.
# police it or fix it.
*$inner->{ZipData}{Streaming} = 0;
*$inner->{ZipData}{Crc32} = $member->{CRC32};
*$inner->{ZipData}{CompressedLen} = $member->{CompressedLength};
lib/Archive/Zip/SimpleUnzip.pm view on Meta::CPAN
'LocalHeaderOffset' => $locHeaderOffset,
'CompressedLength' => $compressedLength ,
'UncompressedLength' => $uncompressedLength ,
'CRC32' => $crc32 ,
#'Time' => _dosToUnixTime($lastModTime),
#'Stream' => $streamingMode,
#'Zip64' => $zip64,
#
#'MethodID' => $compressedMethod,
);
push @CD, \%data;
view all matches for this distribution
view release on metacpan or search on metacpan
t/18_bug_92205.t view on Meta::CPAN
# Archive::Zip was blowing up when processing member
# 'Configurations2/accelerator/current.xml' from the LibreOffice file.
#
# 'current.xml' is a zero length file that has been compressed AND uses
# streaming. That means the uncompressed length is zero but the compressed
# length is greater than 0.
#
# The fix for issue #101092 added code that forced both the uncompressed &
# compressed lengths to be zero if either was zero. That caused this issue.
# This set of test checks that a zero length zip member will ALWAYS be
# mapped to a zero length stored member, regardless of the compression
# method used or the use of streaming.
#
# Input files all contain a single zero length member.
# Streaming & Compression Method are set as follows.
#
# File Streamed Method
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Ark/Context.pm view on Meta::CPAN
and $self->dispatch_auto_action
and $match->dispatch($self);
$self->detached(0);
$self->dispatch_private_action('end')
unless $self->res->is_deferred or $self->res->is_streaming;
}
else {
$self->log( error => 'no action found' );
}
}
view all matches for this distribution
view release on metacpan or search on metacpan
lib/ArrayData/Lingua/Word/EN/Enable.pm view on Meta::CPAN
mainsprings
mainstay
mainstays
mainstream
mainstreamed
mainstreaming
mainstreams
maintain
maintainabilities
maintainability
maintainable
lib/ArrayData/Lingua/Word/EN/Enable.pm view on Meta::CPAN
slipslops
slipsole
slipsoles
slipstream
slipstreamed
slipstreaming
slipstreams
slipt
slipup
slipups
slipware
lib/ArrayData/Lingua/Word/EN/Enable.pm view on Meta::CPAN
streamed
streamer
streamers
streamier
streamiest
streaming
streamings
streamlet
streamlets
streamline
streamlined
streamliner
view all matches for this distribution
view release on metacpan or search on metacpan
lib/ArrayData/Lingua/Word/EN/Medical/Glutanimate.pm view on Meta::CPAN
straw
strawberry
streak
streaks
stream
streaming
streams
streblomicrodactyly
Strecker
street
Streeter
view all matches for this distribution
view release on metacpan or search on metacpan
lib/ArrayData/Word/EN/Enable.pm view on Meta::CPAN
mainsprings
mainstay
mainstays
mainstream
mainstreamed
mainstreaming
mainstreams
maintain
maintainabilities
maintainability
maintainable
lib/ArrayData/Word/EN/Enable.pm view on Meta::CPAN
slipslops
slipsole
slipsoles
slipstream
slipstreamed
slipstreaming
slipstreams
slipt
slipup
slipups
slipware
lib/ArrayData/Word/EN/Enable.pm view on Meta::CPAN
streamed
streamer
streamers
streamier
streamiest
streaming
streamings
streamlet
streamlets
streamline
streamlined
streamliner
view all matches for this distribution
view release on metacpan or search on metacpan
lib/Arriba/Server.pm view on Meta::CPAN
SCRIPT_NAME => '',
'psgi.version' => [ 1, 1 ],
'psgi.errors' => *STDERR,
'psgi.url_scheme' => $req->{scheme},
'psgi.nonblocking' => Plack::Util::FALSE,
'psgi.streaming' => Plack::Util::TRUE,
'psgi.run_once' => Plack::Util::FALSE,
'psgi.multithread' => Plack::Util::FALSE,
'psgi.multiprocess' => Plack::Util::TRUE,
'psgix.io' => $client,
'psgix.input.buffered' => Plack::Util::TRUE,
view all matches for this distribution
view release on metacpan or search on metacpan
docs/api/ExtractText.md view on Meta::CPAN
```
PUT http://api.aspose.cloud/v4.0/cells/content/extract/text
```
### **Function Description**
Extracts substrings, numbers, or fixed-length prefixes/suffixes from the selected range and writes the results directly to the target areaâno Excel formulas, no helper columns, no manual copy-paste.The engine works cell-by-cell:- **String cells** a...
### The request parameters of **extractText** API are:
| Parameter Name | Type | Path/Query String/HTTPBody | Description |
| :- | :- | :- |:- |
view all matches for this distribution
view release on metacpan or search on metacpan
lib/At/Protocol/Firehose.pm view on Meta::CPAN
$fh->start();
=head1 DESCRIPTION
C<At::Protocol::Firehose> handles the real-time streaming of events from an AT Protocol relay or PDS. It decodes the
binary DAG-CBOR messages into Perl data structures using L<Codec::CBOR>.
Each message from the firehose consists of two parts:
=over
view all matches for this distribution
view release on metacpan or search on metacpan
#!/usr/bin/perl -w
# test streaming from files, and error in stream creation
use Test::More tests => 24;
use strict;
BEGIN
view all matches for this distribution
view release on metacpan or search on metacpan
metafile : create_distdir
$(NOECHO) $(ECHO) Generating META.yml
$(NOECHO) $(ECHO) '--- #YAML:1.0' > META_new.yml
$(NOECHO) $(ECHO) 'name: Audio-C4Stream-Wav' >> META_new.yml
$(NOECHO) $(ECHO) 'version: 1.00' >> META_new.yml
$(NOECHO) $(ECHO) 'abstract: Perl extension for open and streaming WAV files.' >> META_new.yml
$(NOECHO) $(ECHO) 'author:' >> META_new.yml
$(NOECHO) $(ECHO) ' - C4PC <adeamara@cloud4pc.com>' >> META_new.yml
$(NOECHO) $(ECHO) 'license: unknown' >> META_new.yml
$(NOECHO) $(ECHO) 'distribution_type: module' >> META_new.yml
$(NOECHO) $(ECHO) 'configure_requires:' >> META_new.yml
# --- MakeMaker ppd section:
# Creates a PPD (Perl Package Description) for a binary distribution.
ppd :
$(NOECHO) $(ECHO) '<SOFTPKG NAME="$(DISTNAME)" VERSION="1.00">' > $(DISTNAME).ppd
$(NOECHO) $(ECHO) ' <ABSTRACT>Perl extension for open and streaming WAV files.</ABSTRACT>' >> $(DISTNAME).ppd
$(NOECHO) $(ECHO) ' <AUTHOR>C4PC <adeamara@cloud4pc.com></AUTHOR>' >> $(DISTNAME).ppd
$(NOECHO) $(ECHO) ' <IMPLEMENTATION>' >> $(DISTNAME).ppd
$(NOECHO) $(ECHO) ' <REQUIRE NAME="Inline::" VERSION="0.44" />' >> $(DISTNAME).ppd
$(NOECHO) $(ECHO) ' <ARCHITECTURE NAME="x86_64-linux-gnu-thread-multi-5.10" />' >> $(DISTNAME).ppd
$(NOECHO) $(ECHO) ' <CODEBASE HREF="" />' >> $(DISTNAME).ppd
view all matches for this distribution
view release on metacpan or search on metacpan
information of track information. Once created, Audio::DB provides
various methods for creating reports and web pages of your
collection. Although it's nutritious and delicious on its own, Audio::DB
was created for use with Apache::MP3::DB, a subclass of Apache::MP3.
This module makes it easy to make your collection web-accessible,
complete with browsing, searching, streaming, multiple users,
playlists, ratings, and more!
=head1 USAGE
There are three central modules that you will be interacting with.
view all matches for this distribution
view release on metacpan or search on metacpan
MPG123/Client.pm view on Meta::CPAN
=item add [list of urls]
Needs to have arguments (array or array ref) of urls to load on the server. If you're calling an mp3
file it obviously needs access by the server, not the client. It can be simple filenames, or urls
including http: urls for streaming to the server. If there are tracks already in the playlist on the server
these will be tacked on to the end of the list. If random mode is on, it will re-randomize the entire list
when it is finished adding (see the random feature).
=item del [list of index numbers]
view all matches for this distribution
view release on metacpan or search on metacpan
use Audio::Daemon::Client;
=head1 DESCRIPTION
Audio::Daemon is a udp service providing a single udp interface around various
other modules, like Xmms, Audio::Play::MPG123 and libshout (for icecast streaming).
=head1 AUTHOR
Jay Jacobs jayj@cpan.org
view all matches for this distribution
view release on metacpan or search on metacpan
/* Allow multiple instances of the decoder object. Stuff each filehandle into (void*)stream */
typedef struct {
int abort_flag;
int bytes_streamed;
int is_streaming;
FLAC__uint64 stream_length;
void *buffer;
PerlIO *stream;
decoder_t *decoder;
FLAC__bool has_replaygain;
FLAC__uint64 absolute_byte_offset, void *client_data) {
flac_datasource *datasource = (flac_datasource *)client_data;
/* can't seek on a socket */
if (datasource->is_streaming) {
return FLAC__STREAM_DECODER_SEEK_STATUS_ERROR;
}
if (PerlIO_seek(datasource->stream, absolute_byte_offset, SEEK_SET) >= 0) {
return FLAC__STREAM_DECODER_SEEK_STATUS_OK;
flac_datasource *datasource = (flac_datasource *)client_data;
FLAC__uint64 pos = -1;
/* can't tell on a socket */
if (datasource->is_streaming) {
return FLAC__STREAM_DECODER_TELL_STATUS_ERROR;
}
pos = PerlIO_tell(datasource->stream);
FLAC__uint64 *stream_length, void *client_data) {
flac_datasource *datasource = (flac_datasource *)client_data;
/* can't find the total length of a socket */
if (datasource->is_streaming) {
return FLAC__STREAM_DECODER_LENGTH_STATUS_ERROR;
}
*stream_length = datasource->stream_length;
return FLAC__STREAM_DECODER_LENGTH_STATUS_OK;
const decoder_t *decoder, void *client_data) {
flac_datasource *datasource = (flac_datasource *)client_data;
FLAC__uint64 pos = 0;
if (datasource->is_streaming) {
return false;
}
pos = PerlIO_tell(datasource->stream);
warn("failed on open: [%d] - [%s]\n", errno, strerror(errno));
XSRETURN_UNDEF;
}
datasource->is_streaming = 0;
} else if (SvOK(path)) {
/* Did we get a Glob, or a IO::Socket subclass?
*
* XXX This should really be a class method so the caller
* can tell us if it's streaming or not. But how to do this on
* a per object basis without changing open()s arugments. That
* may be the easiest/only way. XXX
*
*/
if (sv_isobject(path) && sv_derived_from(path, "IO::Socket")) {
datasource->is_streaming = 1;
} else {
datasource->is_streaming = 0;
}
/* dereference and get the SV* that contains the Magic & FH,
* then pull the fd from the PerlIO object */
datasource->stream = IoIFP(GvIOp(SvRV(path)));
} else {
XSRETURN_UNDEF;
}
if (!datasource->is_streaming) {
pos = PerlIO_tell(datasource->stream);
if (PerlIO_seek(datasource->stream, 0, SEEK_END) != -1) {
HV *self = (HV *) SvRV(obj);
flac_datasource *datasource = (flac_datasource *) SvIV(*(my_hv_fetch(self, "DATASOURCE")));
/* can't seek on a socket. */
if (datasource->is_streaming) {
XSRETURN_UNDEF;
}
if (!FLAC__stream_decoder_reset(datasource->decoder)) {
XSRETURN_UNDEF;
view all matches for this distribution