MCPcopy Index your code
hub / github.com/Effect-TS/effect / collectAllWhileEffect

Function collectAllWhileEffect

packages/effect/src/internal/sink.ts:232–234  ·  view source on GitHub ↗
(
  predicate: (input: In) => Effect.Effect<boolean, E, R>
)

Source from the content-addressed store, hash-verified

230
231/** @internal */
232export const collectAllWhileEffect = <In, E, R>(
233 predicate: (input: In) => Effect.Effect<boolean, E, R>
234): Sink.Sink<Chunk.Chunk<In>, In, In, E, R> => fromChannel(collectAllWhileEffectReader(predicate, Chunk.empty()))
235
236/** @internal */
237const collectAllWhileEffectReader = <In, R, E>(

Callers

nothing calls this directly

Calls 2

collectAllWhileEffectReaderFunction · 0.85
fromChannelFunction · 0.70

Tested by

no test coverage detected