typestream.default.PipelineTransformGeneratortype PipelineTransformGenerator<S extends PipelineTransformSource<any>, O> = (source: PipelineSourceArgument<S>, options?: Abortable) => AsyncIterable<O>