pipeline

internal.internal.pipeline

Functions

__promisify__

promisify<A, B>(source, destination, options?): PipelinePromise<B>

APipelineSource<any>Required

BWritableStream | PipelineDestinationIterableFunction<string | Buffer> | PipelineDestinationPromiseFunction<string | Buffer, any> | PipelineDestinationIterableFunction<any> | PipelineDestinationPromiseFunction<any, any>Required

Parameters

sourceARequired

destinationBRequired

optionsPipelineOptions

Returns

PipelinePromise<B>

PipelinePromisePipelinePromise<B>Required

promisify<A, T1, B>(source, transform1, destination, options?): PipelinePromise<B>

APipelineSource<any>Required

T1PipelineTransform<A, any>Required

BWritableStream | PipelineDestinationIterableFunction<string | Buffer> | PipelineDestinationPromiseFunction<string | Buffer, any> | PipelineDestinationIterableFunction<any> | PipelineDestinationPromiseFunction<any, any>Required

Parameters

sourceARequired

transform1T1Required

destinationBRequired

optionsPipelineOptions

Returns

PipelinePromise<B>

PipelinePromisePipelinePromise<B>Required

promisify<A, T1, T2, B>(source, transform1, transform2, destination, options?): PipelinePromise<B>

APipelineSource<any>Required

T1PipelineTransform<A, any>Required

T2PipelineTransform<T1, any>Required

BWritableStream | PipelineDestinationIterableFunction<string | Buffer> | PipelineDestinationPromiseFunction<string | Buffer, any> | PipelineDestinationIterableFunction<any> | PipelineDestinationPromiseFunction<any, any>Required

Parameters

sourceARequired

transform1T1Required

transform2T2Required

destinationBRequired

optionsPipelineOptions

Returns

PipelinePromise<B>

PipelinePromisePipelinePromise<B>Required

promisify<A, T1, T2, T3, B>(source, transform1, transform2, transform3, destination, options?): PipelinePromise<B>

APipelineSource<any>Required

T1PipelineTransform<A, any>Required

T2PipelineTransform<T1, any>Required

T3PipelineTransform<T2, any>Required

BWritableStream | PipelineDestinationIterableFunction<string | Buffer> | PipelineDestinationPromiseFunction<string | Buffer, any> | PipelineDestinationIterableFunction<any> | PipelineDestinationPromiseFunction<any, any>Required

Parameters

sourceARequired

transform1T1Required

transform2T2Required

transform3T3Required

destinationBRequired

optionsPipelineOptions

Returns

PipelinePromise<B>

PipelinePromisePipelinePromise<B>Required

promisify<A, T1, T2, T3, T4, B>(source, transform1, transform2, transform3, transform4, destination, options?): PipelinePromise<B>

APipelineSource<any>Required

T1PipelineTransform<A, any>Required

T2PipelineTransform<T1, any>Required

T3PipelineTransform<T2, any>Required

T4PipelineTransform<T3, any>Required

BWritableStream | PipelineDestinationIterableFunction<string | Buffer> | PipelineDestinationPromiseFunction<string | Buffer, any> | PipelineDestinationIterableFunction<any> | PipelineDestinationPromiseFunction<any, any>Required

Parameters

sourceARequired

transform1T1Required

transform2T2Required

transform3T3Required

transform4T4Required

destinationBRequired

optionsPipelineOptions

Returns

PipelinePromise<B>

PipelinePromisePipelinePromise<B>Required

promisify(streams, options?): Promise<void>

Parameters

streamsreadonly (ReadableStream | WritableStream | ReadWriteStream)[]Required

optionsPipelineOptions

Returns

Promise<void>

PromisePromise<void>Required

promisify(stream1, stream2, ...streams): Promise<void>

Parameters

stream1ReadableStreamRequired

stream2WritableStream | ReadWriteStreamRequired

streams(WritableStream | ReadWriteStream | PipelineOptions)[]Required

Returns

Promise<void>

PromisePromise<void>Required