⚠️ Internal: This API is not publically exported by the package.

      Type alias PipelineDestinationPromiseFunction<T, P>

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

      Type Parameters

      • T

      • P

      Type declaration

        • (source): Promise<P>
        • Parameters

          • source: AsyncIterable<T>

          Returns Promise<P>