@metreeca/pipe - v0.9.11
    Preparing search index...

    Interface Sink<V, R>

    Terminal operation that consumes a stream and produces a result.

    Sinks trigger stream execution and return a promise that resolves when all items have been processed.

    Type Parameters

    • V

      The type of input values

    • R = V

      The type of result (defaults to V)

    • Consumes an async iterable and produces a final result.

      Parameters

      • value: AsyncIterable<V>

        The source async iterable to consume

      Returns Promise<R>

      A promise resolving to the final result