UNPKG

568 BTypeScriptView Raw
1/// <reference types="node" />
2import { TransformOptions, WritableTyped } from '../stream.model';
3/**
4 * Allows "forking" a stream inside pipeline into a number of pipeline chains (2 or more).
5 * Currently does NOT (!) maintain backpressure.
6 * Error in the forked pipeline will propagate up to the main pipeline (and log error, to be sure).
7 * Will wait until all forked pipelines are completed before completing the stream.
8 *
9 * @experimental
10 */
11export declare function writableFork<T>(chains: NodeJS.WritableStream[][], opt?: TransformOptions): WritableTyped<T>;