Type Alias PipelineTransform<S, U>

PipelineTransform<S, U>: ReadWriteStream | ((source: S extends ((...args: any[]) => Iterable<infer ST> | AsyncIterable<infer ST>)
    ? AsyncIterable<ST>
    : S) => AsyncIterable<U>)

Type Parameters