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

    Module sinks

    Terminal operations that consume streams and produce final results.

    Sinks trigger stream execution and return promises that resolve when processing completes. They represent the final stage in a pipeline, collecting, aggregating, or validating stream data.

    Functions

    some

    Creates a sink checking if any item satisfies the predicate.

    every

    Creates a sink checking if all items satisfy the predicate.

    count

    Creates a sink counting the total number of items in the stream.

    find

    Creates a sink retrieving the first item that satisfies the predicate.

    forEach

    Creates a sink executing a side effect for each item and consuming the stream.

    reduce

    Creates a sink reducing the stream to a single value without an initial value.

    toArray

    Creates a sink collecting all items into an array.

    toSet

    Creates a sink collecting all unique items into a set.

    toMap

    Creates a sink collecting items into a map using item values.

    toString

    Creates a sink joining all items into a string using a separator.