streaming results from the CPAN

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

1 match

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

1 match

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

2 results

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

1 match

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


  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

1 match

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


  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

1 match

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


  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

1 match

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

1 match

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

1 match

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

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

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

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

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

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

1 match

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

1 match

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

1 match

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

Lingua-Stem

2 results

examples/collected_works_poe.txt view on Meta::CPAN

my final overthrow. It was this unfathomable longing of the soul _to
vex itself_ - to offer violence to its own nature - to do wrong for
the wrong's sake only - that urged me to continue and finally to
consummate the injury I had inflicted upon the unoffending brute. One
morning, in cool blood, I slipped a noose about its neck and hung it
to the limb of a tree; - hung it with the tears streaming from my
eyes, and with the bitterest remorse at my heart; - hung it _because_
I knew that it had loved me, and _because_ I felt it had given me no
reason of offence; - hung it _because_ I knew that in so doing I was
committing a sin - a deadly sin that would so jeopardize my immortal
soul as to place it - if such a thing wore possible - even beyond the

examples/collected_works_poe.txt view on Meta::CPAN

now wore an energetic and human expression, while they gleamed with a
fiery and unusual red; and the distended lips of the apparently
enraged horse left in full view his gigantic and disgusting teeth.

    Stupified with terror, the young nobleman tottered to the door.
As he threw it open, a flash of red light, streaming far into the
chamber, flung his shadow with a clear outline against the quivering
tapestry, and he shuddered to perceive that shadow - as he staggered
awhile upon the threshold - assuming the exact position, and
precisely filling up the contour, of the relentless and triumphant
murderer of the Saracen Berlifitzing.

examples/collected_works_poe.txt view on Meta::CPAN

bounded far up the tottering staircases of the palace, and, with its
rider, disappeared amid the whirlwind of chaotic fire.

    The fury of the tempest immediately died away, and a dead calm
sullenly succeeded. A white flame still enveloped the building like a
shroud, and, streaming far away into the quiet atmosphere, shot forth
a glare of preternatural light; while a cloud of smoke settled
heavily over the battlements in the distinct colossal figure of - _a
horse_.

examples/collected_works_poe.txt view on Meta::CPAN

yet most terrible of all we have encountered in our flight? Its
brilliant flowers look like a fairy dream -- but its fierce volcanoes
like the passions of a turbulent heart.

AGATHOS. They are! -- they are! This wild star -- it is now three
centuries since, with clasped hands, and with streaming eyes, at the
feet of my beloved -- I spoke it -- with a few passionate sentences
-- into birth. Its brilliant flowers are the dearest of all
unfulfilled dreams, and its raging volcanoes are the passions of the
most turbulent and unhallowed of hearts.

examples/collected_works_poe.txt view on Meta::CPAN

                        Quoth the raven, "Nevermore."

And the raven, never flitting, still is sitting, still is sitting
On the pallid bust of Pallas just above my chamber door;
And his eyes have all the seeming of a demon's that is dreaming,
And the lamp-light o'er him streaming throws his shadow on the floor;
And my soul from out that shadow that lies floating on the floor
                         Shall be lifted -- nevermore!

~~~ End of Text ~~~

view all matches for this distribution

Lingua-ZH-Jieba

16 results

cppjieba/deps/gtest/include/gtest/gtest-message.h view on Meta::CPAN

  // stream a pointer to a Message, this definition will be used as it
  // is more specialized.  (The C++ Standard, section
  // [temp.func.order].)  If you stream a non-pointer, then the
  // previous definition will be used.
  //
  // The reason for this overload is that streaming a NULL pointer to
  // ostream is undefined behavior.  Depending on the compiler, you
  // may get "0", "(nil)", "(null)", or an access violation.  To
  // ensure consistent result across compilers, we always treat NULL
  // as "(null)".
  template <typename T>

cppjieba/deps/gtest/include/gtest/gtest-message.h view on Meta::CPAN

#endif  // GTEST_OS_SYMBIAN

  // Since the basic IO manipulators are overloaded for both narrow
  // and wide streams, we have to provide this specialized definition
  // of operator <<, even though its body is the same as the
  // templatized version above.  Without this definition, streaming
  // endl or other basic IO manipulators to Message will confuse the
  // compiler.
  Message& operator <<(BasicNarrowIoManip val) {
    *ss_ << val;
    return *this;

cppjieba/deps/gtest/include/gtest/gtest-message.h view on Meta::CPAN

  // Instead of 1/0, we want to see true/false for bool values.
  Message& operator <<(bool b) {
    return *this << (b ? "true" : "false");
  }

  // These two overloads allow streaming a wide C string to a Message
  // using the UTF-8 encoding.
  Message& operator <<(const wchar_t* wide_c_str) {
    return *this << internal::String::ShowWideCString(wide_c_str);
  }
  Message& operator <<(wchar_t* wide_c_str) {

view all matches for this distribution

Linux-Inotify2

1 match

Changes view on Meta::CPAN

        - no internal changes.

1.01 Tue Dec 20 12:31:16 CET 2005
	- more fixes by Andrejs Dubovskis:
	- removed debugging code accidentally left in.
        - streaming API didn't always return properly blessed objects.

1.0  Mon Dec 19 17:48:01 CET 2005
	- incorporated a major patch by Andrejs Dubovskis:
        - added a non-callback interface to read events
        - better error handling in non-blocking case.

view all matches for this distribution

LyricFinder

2 results

lib/LyricFinder.pm view on Meta::CPAN

lyrics sites, as needed/desired by the user programatically.

We've also changed the default to search the supported sites randomly, instead 
of in the same fixed alphabetical order by module name ("load-balancing" the 
searches to all the sites).  This is helpful when using LyricFinder as a 
plugin for streaming media players, such as the author's very own "Fauxdacious 
Media Player" that frequently stream internet radio stations, which can 
impose a "hit" on the lyrics sites each time the song title changes.  This 
reduces the odds of a user's IP-address possibly being banned by a lyrics site 
for "too-frequent scraping / usage"!  NOTE:  If you want to prevent the usage 
of one or more of the specific sites, simply specify the I<-omit> argument with

view all matches for this distribution

MARC-Schema

1 match

share/marc-schema.json view on Meta::CPAN

{"$schema":"https://format.gbv.de/schema/avram/schema.json","title":"MARC 21 Format for Bibliographic Data.","description":"MARC 21 Format for Bibliographic Data.","url":"https://www.loc.gov/marc/bibliographic/","fields":{"LDR":{"repeatable":false,"p...

view all matches for this distribution

MHFS-XS

1 match


1.2. High Level API
-------------------
The high level API consists of three main parts:

  * Resource management for loading and streaming sounds.
  * A node graph for advanced mixing and effect processing.
  * A high level "engine" that wraps around the resource manager and node graph.

The resource manager (`ma_resource_manager`) is used for loading sounds. It supports loading sounds
fully into memory and also streaming. It will also deal with reference counting for you which
avoids the same sound being loaded multiple times.

The node graph is used for mixing and effect processing. The idea is that you connect a number of
nodes into the graph by connecting each node's outputs to another node's inputs. Each node can
implement it's own effect. By chaining nodes together, advanced mixing and effect processing can


    ```c
    ma_sound_init_from_file(&engine, "my_sound.wav", MA_SOUND_FLAG_STREAM, pGroup, NULL, &sound);
    ```

When streaming sounds, 2 seconds worth of audio data is stored in memory. Although it should work
fine, it's inefficient to use streaming for short sounds. Streaming is useful for things like music
tracks in games.

When you initialize a sound, if you specify a sound group the sound will be attached to that group
automatically. If you set it to NULL, it will be automatically attached to the engine's endpoint.
If you would instead rather leave the sound unattached by default, you can can specify the



6. Resource Management
======================
Many programs will want to manage sound resources for things such as reference counting and
streaming. This is supported by miniaudio via the `ma_resource_manager` API.

The resource manager is mainly responsible for the following:

  * Loading of sound files into memory with reference counting.
  * Streaming of sound data

available because the asynchronous decoding hasn't caught up, `MA_BUSY` will be returned by
`ma_data_source_read_pcm_frames()`.

For large sounds, it's often prohibitive to store the entire file in memory. To mitigate this, you
can instead stream audio data which you can do by specifying the
`MA_RESOURCE_MANAGER_DATA_SOURCE_FLAG_STREAM` flag. When streaming, data will be decoded in 1
second pages. When a new page needs to be decoded, a job will be posted to the job queue and then
subsequently processed in a job thread.

For in-memory sounds, reference counting is used to ensure the data is loaded only once. This means
multiple calls to `ma_resource_manager_data_source_init()` with the same file path will result in

---------------------------------------------
When loading asynchronously, it can be useful to poll whether or not loading has finished. Use
`ma_resource_manager_data_source_result()` to determine this. For in-memory sounds, this will
return `MA_SUCCESS` when the file has been *entirely* decoded. If the sound is still being decoded,
`MA_BUSY` will be returned. Otherwise, some other error code will be returned if the sound failed
to load. For streaming data sources, `MA_SUCCESS` will be returned when the first page has been
decoded and the sound is ready to be played. If the first page is still being decoded, `MA_BUSY`
will be returned. Otherwise, some other error code will be returned if the sound failed to load.

In addition to polling, you can also use a simple synchronization object called a "fence" to wait
for asynchronously loaded sounds to finish. This is called `ma_fence`. The advantage to using a

6.2. Resource Manager Implementation Details
--------------------------------------------
Resources are managed in two main ways:

  * By storing the entire sound inside an in-memory buffer (referred to as a data buffer)
  * By streaming audio data on the fly (referred to as a data stream)

A resource managed data source (`ma_resource_manager_data_source`) encapsulates a data buffer or
data stream, depending on whether or not the data source was initialized with the
`MA_RESOURCE_MANAGER_DATA_SOURCE_FLAG_STREAM` flag. If so, it will make use of a
`ma_resource_manager_data_stream` object. Otherwise it will use a `ma_resource_manager_data_buffer`

determine the required size of the output buffer. frameCountOut should be set to the capacity of pOut. If pOut is NULL, frameCountOut is
ignored.

A return value of 0 indicates an error.

This function is useful for one-off bulk conversions, but if you're streaming data you should use the ma_data_converter APIs instead.
*/
MA_API ma_uint64 ma_convert_frames(void* pOut, ma_uint64 frameCountOut, ma_format formatOut, ma_uint32 channelsOut, ma_uint32 sampleRateOut, const void* pIn, ma_uint64 frameCountIn, ma_format formatIn, ma_uint32 channelsIn, ma_uint32 sampleRateIn);
MA_API ma_uint64 ma_convert_frames_ex(void* pOut, ma_uint64 frameCountOut, const void* pIn, ma_uint64 frameCountIn, const ma_data_converter_config* pConfig);

    ma_resource_manager_data_buffer_node* pRootDataBufferNode;      /* The root buffer in the binary tree. */
#ifndef MA_NO_THREADING
    ma_mutex dataBufferBSTLock;                                     /* For synchronizing access to the data buffer binary tree. */
    ma_thread jobThreads[MA_RESOURCE_MANAGER_MAX_JOB_THREAD_COUNT]; /* The threads for executing jobs. */
#endif
    ma_job_queue jobQueue;                                          /* Multi-consumer, multi-producer job queue for managing jobs for asynchronous decoding and streaming. */
    ma_default_vfs defaultVFS;                                      /* Only used if a custom VFS is not specified. */
    ma_log log;                                                     /* Only used if no log was specified in the config. */
};

/* Init. */

resume the stream naively. This means that starting the stream requires us to write data to the stream from outside the callback. This
disconnect is something PulseAudio has got seriously wrong - there should only ever be a single source of data delivery, that being the
callback. (I have tried using `pa_stream_flush()` to trigger the write callback to fire, but this just doesn't work for some reason.)

Once you've created the stream, you need to connect it which involves the whole waiting procedure. This is the same process as the context,
only this time you'll poll for the state with `pa_stream_get_status()`. The starting and stopping of a streaming is referred to as
"corking" in PulseAudio. The analogy is corking a barrel. To start the stream, you uncork it, to stop it you cork it. Personally I think
it's silly - why would you not just call it "starting" and "stopping" like any other normal audio API? Anyway, the act of corking is, you
guessed it, asynchronous. This means you'll need our waiting loop as usual. Again, why this asynchronous design is the default is
absolutely beyond me. Would it really be that hard to just make it run synchronously?

view all matches for this distribution

MIDI-SoundFont

1 match

static int32 ok_nv_sample = 0;
static int ok_nv = 32;
static int old_rate = -1;
#endif

static int midi_streaming = 0;
int volatile stream_max_compute = 500; /* compute time limit (in msec) when streaming */
static int prescanning_flag;
static int32 midi_restart_time = 0;
Channel channel[MAX_CHANNELS];
int max_voices = DEFAULT_VOICES;
Voice *voice = NULL;

			else
				CLEAR_CHANNELMASK(channel_mute);
		}
		for (i = 0; i < MAX_CHANNELS; i++)
			redraw_controllers(i);
		if (midi_streaming && free_instruments_afterwards) {
			free_instruments(0);
			/* free unused memory */
			cnt = free_global_mblock();
			if (cnt > 0)
				ctl->cmsg(CMSG_INFO, VERB_VERBOSE,

    if(cet > current_sample)
    {
	int rc;


    if(midi_streaming!=0){
    	if ( (cet - current_sample) * 1000 / play_mode->rate > stream_max_compute ) {
			kill_all_voices();
			/* reset_voices(); */
/* 			ctl->cmsg(CMSG_INFO, VERB_DEBUG_SILLY, "play_event: discard %d samples", cet - current_sample); */
			current_sample = cet;

    if(first)
    {
	first = 0;
        init_mblock(&playmidi_pool);
	current_file_info = get_midi_file_info("TiMidity", 1);
    midi_streaming=1;
    }
    else
        reuse_mblock(&playmidi_pool);

    /* Fill in current_file_info */

view all matches for this distribution

MIME-DB

1 match

lib/MIME/DB.pm view on Meta::CPAN

$VERSION = 'v1.52.0';
# generation date: 2023-01-31T03:41:54Z
# command: tools\generate.pl
# source url: https://cdn.jsdelivr.net/gh/jshttp/mime-db@v1.52.0/db.json
use constant version => 'v1.52.0';
sub data { {'application/mud+json',{source=>'iana',compressible=>1},'application/vnd.commonspace',{extensions=>['csp'],source=>'iana'},'text/x-handlebars-template',{extensions=>['hbs']},'application/vnd.dbf',{source=>'iana',extensions=>['dbf']},'appl...
1

view all matches for this distribution

MIME-Type-FileName

1 match

lib/MIME/Type/FileName.pm view on Meta::CPAN

spl 	application/futuresplash
spr 	application/x-sprite
sprite 	application/x-sprite
src 	application/x-wais-source
ssi 	text/x-server-parsed-html
ssm 	application/streamingmedia
sst 	application/vnd.ms-pki.certstore
step 	application/step
stl 	application/sla
stl 	application/vnd.ms-pki.stl
stl 	application/x-navistyle

view all matches for this distribution

MIME-Types

1 match

lib/MIME/types.db view on Meta::CPAN

ssa;text/x-ssa
ssdl;application/x-ssdl+xml
sse;application/vnd.kodak-descriptor
ssf;application/vnd.epson.ssf
ssi;text/x-server-parsed-html
ssm;application/x-streamingmedia
ssml;application/ssml+xml
sst;application/vnd.ms-pki.certstore
ssv;application/vnd.crypto-shade-file
ssvc;application/vnd.crypto-shade-file
ssw;video/vnd.sealed.swf

lib/MIME/types.db view on Meta::CPAN

x-spss-sav;sav,zsav;;
x-spss;sav,sbs,sps,spo,spp;;
x-sql;sql;;
x-ssdl+xml;ssdl;;
x-step;step,stp;;
x-streamingmedia;ssm;;
x-stuffit;sit,sitx;base64;
x-stuffitx;sitx;;
x-subrip;srt;;
x-sv4cpio;sv4cpio;base64;
x-sv4crc;sv4crc;base64;

lib/MIME/types.db view on Meta::CPAN

vnd.ntt-local.sip-ta_tcp_stream;;;
vnd.obn;;;
vnd.ocf+cbor;;;
vnd.oci.image.manifest.v1+json;;;
vnd.oipf.contentaccessdownload+xml;;;
vnd.oipf.contentaccessstreaming+xml;;;
vnd.oipf.cspg-hexbinary;;;
vnd.oipf.dae.svg+xml;;;
vnd.oipf.dae.xhtml+xml;;;
vnd.oipf.mippvcontrolmessage+xml;;;
vnd.oipf.pae.gem;;;

view all matches for this distribution

MOP4Import-Declare

1 match

PSGIEnv.pm view on Meta::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