stream.default.PipelineTransform

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