Documentation
    Preparing search index...

    Function accumulate

    • Every chunk is transformed in to an accumulator.

      Type Parameters

      • I
      • O

      Parameters

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

      Returns TransformStream<I, O>

      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}----