effect-io-ai

Package: effect
Module: Stream

Stream.accumulate

Collects each underlying Chunk of the stream into a new chunk, and emits it on each pull.

Signature

declare const accumulate: <A, E, R>(self: Stream<A, E, R>) => Stream<Chunk.Chunk<A>, E, R>

Source

Since v2.0.0