/// import { Readable } from 'stream'; import { SequenceOptions } from './sequenceOptions'; /** * Wraps multiple readable streams into a sequence */ export default class Sequence extends Readable { /** * @param objectMode Object mode setting * @param abortOnError True if error in sequence should emit error, false otherwise */ static DEFAULT_OPTIONS: { objectMode: boolean; abortOnError: boolean; }; private _options; private _context; private _stream; private readonly _nextStreamGetter?; private readonly _onStreamEndHandler; private readonly _onStreamCloseHandler; private readonly _onStreamDataHandler; private readonly _onStreamErrorHandler; /** * @constructor * @param sequence Functor-factory or array of Readable streams * @param options Sequence options */ constructor(sequence: Function | Array, options?: SequenceOptions); /** * https://nodejs.org/api/stream.html#stream_readable_read_size_1 */ _read(size: any): void; /** * https://nodejs.org/api/stream.html#stream_readable_destroy_err_callback */ _destroy(error: any, callback: any): void; /** * Obtains next stream */ _obtainNextStream(): void; /** * Detaches from current stream */ _detachFromStream(): void; /** * Handles stream end event */ _onStreamEnd(): void; /** * Handles stream close event */ _onStreamClose(): void; /** * Handles stream error event */ _onStreamError(error: Error): void; /** * Handles stream readable event */ _onStreamData(chunk: any): void; }