effect-io-ai

Package: effect
Module: Sink

Sink.collectAllUntilEffect

Accumulates incoming elements into a chunk until effectful predicate p is satisfied.

Signature

declare const collectAllUntilEffect: <In, E, R>(p: (input: In) => Effect.Effect<boolean, E, R>) => Sink<Chunk.Chunk<In>, In, In, E, R>

Source

Since v2.0.0