Type Alias PipelineDestinationPromiseFunction<T, P>

PipelineDestinationPromiseFunction: (source: AsyncIterable<T>) => Promise<P>

Type Parameters

  • T
  • P