typestream.default.PipelineDestinationFunctiontype PipelineDestinationFunction<S extends PipelineTransformSource<any>, R> = (source: PipelineSourceArgument<S>, options?: Abortable) => R