effect-io-ai

Package: effect
Module: Stream

Stream.bufferChunks

Allows a faster producer to progress independently of a slower consumer by buffering up to capacity chunks in a queue.

Signature

declare const bufferChunks: { (options: { readonly capacity: number; readonly strategy?: "dropping" | "sliding" | "suspend" | undefined; }): <A, E, R>(self: Stream<A, E, R>) => Stream<A, E, R>; <A, E, R>(self: Stream<A, E, R>, options: { readonly capacity: number; readonly strategy?: "dropping" | "sliding" | "suspend" | undefined; }): Stream<A, E, R>; }

Source

Since v2.0.0