Type alias PipelineDestinationPromiseFunction<T, P>

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

Type Parameters

T
P

Type declaration

- (source: AsyncIterable<T>): Promise<P>
- Parameters
  - source: AsyncIterable<T>
  Returns Promise<P>