Function accumulate

  • accumulate<I, O>(acc, fn): TransformStream<I, O>

  • Every chunk is transformed in to an accumulator.

    Type Parameters

    • I

    • O

    Parameters

    • acc: O
    • fn: Accumulator<I, O>

    Returns TransformStream<I, O>

    See

    reduce:function

    Example

    Accumulate all previous chunks with a counter.

    --0-------------------------1-------------------------------

    accumulate({ chunks: [], counter: 0 }, (acc, chunk) => ({
      chunks: [...acc.chunks, chunk],
      counter: acc.counter + 1
    }))

    ----{chunks:[0],counter:1}------{chunks:[0,1],counter:2}----

Settings

Member Visibility

Theme

Generated using TypeDoc