PipelineDestinationPromiseFunction

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

Type parameters

TobjectRequired

PobjectRequired

Type declaration

Parameters

sourceAsyncIterable<T>Required

Returns

PromisePromise<P>Required