/* * @license Apache-2.0 * * Copyright (c) 2021 The Stdlib Authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ // TypeScript Version: 4.1 /// import { Transform } from 'stream'; /** * Interface defining stream options. */ interface Options { /** * Specifies whether a stream should operate in object mode (default: `false`). */ objectMode?: boolean; /** * Specifies how `Buffer` objects should be decoded to strings (default: `null`). */ encoding?: string | null; /** * Specifies the `Buffer` level for when `write()` starts returning `false`. */ highWaterMark?: number; /** * Separator used to join streamed data (default: `/\r?\n/`). */ sep?: string | RegExp; /** * Specifies whether the stream should remain open even if one side ends (default: `false`). */ allowHalfOpen?: boolean; /** * Specifies whether the readable side should be in object mode (default: `false`). */ readableObjectMode?: boolean; } /** * Interface defining a stream constructor which is both "newable" and "callable". */ interface Constructor { /** * Split stream constructor. * * @param options - stream options * @param options.sep - separator used to split streamed data (default: /\r?\n/) * @param options.objectMode - specifies whether a stream should operate in object mode (default: false) * @param options.encoding - specifies how `Buffer` objects should be decoded to `strings` (default: null) * @param options.highWaterMark - specifies the `Buffer` level for when `write()` starts returning `false` * @param options.allowHalfOpen - specifies whether the stream should remain open even if one side ends (default: false) * @param options.writableObjectMode - specifies whether the writable side should be in object mode (default: false) * @returns split stream * * @example * var SplitStream = splitStream; * var stream = new SplitStream(); * * stream.write( '1\n2\n3' ); * stream.end(); */ new( options?: Options ): Transform; // newable /** * Split stream constructor. * * @param options - stream options * @param options.sep - separator used to split streamed data (default: /\r?\n/) * @param options.objectMode - specifies whether a stream should operate in object mode (default: false) * @param options.encoding - specifies how `Buffer` objects should be decoded to `strings` (default: null) * @param options.highWaterMark - specifies the `Buffer` level for when `write()` starts returning `false` * @param options.allowHalfOpen - specifies whether the stream should remain open even if one side ends (default: false) * @param options.writableObjectMode - specifies whether the writable side should be in object mode (default: false) * @returns split stream * * @example * var stream = splitStream(); * * stream.write( '1\n2\n3' ); * stream.end(); */ ( options?: Options ): Transform; // callable /** * Creates a reusable stream factory. * * @param options - stream options * @param options.sep - separator used to split streamed data (default: /\r?\n/) * @param options.objectMode - specifies whether a stream should operate in object mode (default: false) * @param options.encoding - specifies how `Buffer` objects should be decoded to `strings` (default: null) * @param options.highWaterMark - specifies the `Buffer` level for when `write()` starts returning `false` * @param options.allowHalfOpen - specifies whether the stream should remain open even if one side ends (default: false) * @param options.writableObjectMode - specifies whether the writable side should be in object mode (default: false) * @returns stream factory * * @example * var opts = { * 'sep': '\t', * 'objectMode': true, * 'encoding': 'utf8' * }; * * var factory = splitStream.factory( opts ); * * // Create 10 identically configured streams... * var streams = []; * var i; * for ( i = 0; i < 10; i++ ) { * streams.push( factory() ); * } */ factory( options?: Options ): () => Transform; /** * Returns a stream with `objectMode` set to `true`. * * @param options - stream options * @param options.sep - separator used to split streamed data (default: /\r?\n/) * @param options.encoding - specifies how `Buffer` objects should be decoded to `strings` (default: null) * @param options.highWaterMark - specifies the `Buffer` level for when `write()` starts returning `false` * @param options.allowHalfOpen - specifies whether the stream should remain open even if one side ends (default: false) * @param options.writableObjectMode - specifies whether the writable side should be in object mode (default: false) * @throws must provide valid options * @returns split stream * * @example * var stream = splitStream.objectMode({ * 'sep': ',' * }); * * stream.write( 'a,b,c' ); * stream.end(); */ objectMode( options?: Options ): Transform; } /** * Returns a split stream. * * @param options - stream options * @throws must provide valid options * @returns stream instance * * @example * var SplitStream = splitStream; * var stream = new SplitStream(); * * stream.write( '1\n2\n3' ); * stream.end(); * * @example * var stream = splitStream(); * * stream.write( '1\n2\n3' ); * stream.end(); * * @example * var opts = { * 'sep': '\t', * 'objectMode': true, * 'encoding': 'utf8' * }; * * var factory = splitStream.factory( opts ); * * // Create 10 identically configured streams... * var streams = []; * var i; * for ( i = 0; i < 10; i++ ) { * streams.push( factory() ); * } * * @example * var stream = splitStream.objectMode({ * 'sep': ',' * }); * * stream.write( 'a,b,c' ); * stream.end(); */ declare var splitStream: Constructor; // EXPORTS // export = splitStream;