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>)