/// import { Transform } from 'stream'; import { MapperOptions } from './mapperOptions'; /** * Maps input stream to derivative readable stream */ export default class Mapper extends Transform { /** * @param inputObjectMode True if input data is object stream, false if raw data chunks * @param outputObjectMode True if output data is object stream, false if raw data chunks * @param abortOnError True if error in derivative stream should emit error, false otherwise */ static DEFAULT_OPTIONS: MapperOptions; private _factory; private _options; private _stream; private _notifyTransformComplete; private readonly _onStreamEndHandler; private readonly _onStreamCloseHandler; private readonly _onStreamErrorHandler; private readonly _onStreamDataHandler; /** * @constructor * * @param factory Derivative stream factory * @param options Mapping options */ constructor(factory: Function, options?: MapperOptions); /** * https://nodejs.org/api/stream.html#stream_transform_transform_chunk_encoding_callback * @override */ _transform(chunk: Buffer | string | any, encoding: string, callback: Function): void; /** * https://nodejs.org/api/stream.html#stream_writable_destroy_err_callback * @override */ _destroy(error: Error, callback: any): 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; }