8000 GitHub - stdlib-js/streams-node-from-constant at deno
[go: up one dir, main page]

Skip to content

stdlib-js/streams-node-from-constant

 
 

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

About stdlib...

We believe in a future in which the web is a preferred environment for numerical computation. To help realize this future, we've built stdlib. stdlib is a standard library, with an emphasis on numerical and scientific computation, written in JavaScript (and C) for execution in browsers and in Node.js.

The library is fully decomposable, being architected in such a way that you can swap out and mix and match APIs and functionality to cater to your exact preferences and use cases.

When you use stdlib, you can be absolutely certain that you are using the most thorough, rigorous, well-written, studied, documented, tested, measured, and high-quality code out there.

To join us in bringing numerical computing to the web, get started by checking us out on GitHub, and please consider financially supporting stdlib. We greatly appreciate your continued support!

Constant Stream

NPM version Build Status Coverage Status

Create a readable stream which always streams the same value.

Usage

import constantStream from 'https://cdn.jsdelivr.net/gh/stdlib-js/streams-node-from-constant@deno/mod.js';

You can also import the following named exports from the package:

import { factory, objectMode } from 'https://cdn.jsdelivr.net/gh/stdlib-js/streams-node-from-constant@deno/mod.js';

constantStream( value[, options] )

Returns a readable stream which always streams the same value.

import inspectStream from 'https://cdn.jsdelivr.net/gh/stdlib-js/streams-node-inspect-sink@deno/mod.js';

var iStream;
var stream;

function log( chunk, i ) {
    console.log( chunk.toString() );
    if ( i === 10 ) {
        stream.destroy();
    }
}

stream = constantStream( 'beep' );
iStream = inspectStream( log );

stream.pipe( iStream );

The function accepts the following options:

  • objectMode: specifies whether a stream should operate in objectMode. Default: false.
  • encoding: specifies how Buffer objects should be decoded to strings. Default: null.
  • highWaterMark: specifies the maximum number of bytes to store in an internal buffer before pausing streaming.
  • sep: separator used to join streamed data. This option is only applicable when a stream is not in objectMode. Default: '\n'.
  • iter: number of iterations.

To set stream options,

var opts = {
    'objectMode': true,
    'encoding': 'utf8',
    'highWaterMark': 64
};

var stream = constantStream( 'beep', opts );

By default, the function returns a stream which streams an infinite number of values (i.e., the stream will never end). To limit the number of streamed values, set the iter option.

import inspectStream from 'https://cdn.jsdelivr.net/gh/stdlib-js/streams-node-inspect-sink@deno/mod.js';

function log( chunk ) {
    console.log( chunk.toString() );
}

var opts = {
    'iter': 10
};

var stream = constantStream( 'beep', opts );
var iStream = inspectStream( log );

stream.pipe( iStream );

By default, when not operating in objectMode, a returned stream delineates streamed values using a newline character. To specify an alternative separator, set the sep option.

import inspectStream from 'https://cdn.jsdelivr.net/gh/stdlib-js/streams-node-inspect-sink@deno/mod.js';

function log( chunk ) {
    console.log( chunk.toString() );
}

var opts = {
    'iter': 10,
    'sep': ','
};

var stream = constantStream( 'beep', opts );
var iStream = inspectStream( log );

stream.pipe( iStream );

constantStream.factory( [value, ][options] )

Returns a function for creating readable streams which always stream the same provided value.

var opts = {
    'objectMode': true,
    'encoding': 'utf8',
    'highWaterMark': 64
};

var createStream = constantStream.factory( opts );

If provided a value to stream, the returned function returns readable streams which always stream the same value.

var createStream = constantStream.factory( 'beep' );

var stream1 = createStream();
var stream2 = createStream();
// ...

If not provided a value to stream, the returned function requires that a value be provided at each invocation.

var createStream = constantStream.factory();

var stream1 = createStream( 'beep' );
var stream2 = createStream( 'boop' );
// ...

The method accepts the same options as constantStream().


constantStream.objectMode( value[, options] )

This method is a convenience function to create streams which always operate in objectMode.

import inspectStream from 'https://cdn.jsdelivr.net/gh/stdlib-js/streams-node-inspect-sink@deno/mod.js';

function log( v ) {
    console.log( v );
}

var value = {
    'beep': 'boop'
};
var opts = {
    'iter': 10
};
var stream = constantStream.objectMode( value, opts );

opts = {
    'objectMode': true
};
var iStream = inspectStream( opts, log );

stream.pipe( iStream );

This method accepts the same options as constantStream(); however, the method will always override the objectMode option in options.


Notes

  • In binary mode, a provided value must be a string, Buffer, or Uint8Array.
  • In objectMode, null is a reserved value. If provided null, the returned stream will prematurely end.
  • If provided an object reference, the value is not copied. To avoid unwanted mutation, copy the value before creating a stream.
  • In older Node.js environments, Uint8Array contents may be copied to a new Buffer object due to changes in the underlying Node.js APIs.
  • If the factory method is provided only one argument and that argument is an object (either empty or not containing any recognized options properties), the method treats the argument as a value to be streamed, not as an options argument.

Examples

import inspectStream from 'https://cdn.jsdelivr.net/gh/stdlib-js/streams-node-inspect-sink@deno/mod.js';
import constantStream from 'https://cdn.jsdelivr.net/gh/stdlib-js/streams-node-from-constant@deno/mod.js';

function log( v ) {
    console.log( v.toString() );
}

var opts = {
    'objectMode': true,
    'iter': 10
};

var stream = constantStream( 3.14, opts );

opts = {
    'objectMode': true
};
var iStream = inspectStream( opts, log );

stream.pipe( iStream );

See Also


Notice

This package is part of stdlib, a standard library with an emphasis on numerical and scientific computing. The library provides a collection of robust, high performance libraries for mathematics, statistics, streams, utilities, and more.

For more information on the project, filing bug reports and feature requests, and guidance on how to develop stdlib, see the main project repository.

Community

Chat


License

See LICENSE.

Copyright

Copyright © 2016-2024. The Stdlib Authors.

0