type
stream.default.PipelineTransform
type PipelineTransform<S extends PipelineTransformSource<any>, O> = S extends PipelineSource<infer I> | PipelineTransformStreams<any, infer I> | (...args: any[]) => infer I ? PipelineTransformStreams<I, O> | PipelineTransformGenerator<S, O> : never