typestream.default.PipelineDestinationIterableFunctiontype PipelineDestinationIterableFunction<T> = (source: AsyncIterable<T>) => AsyncIterable<any>