effect-io-ai

Package: effect
Module: SingleProducerAsyncInput

SingleProducerAsyncInput.AsyncInputConsumer

Consumer-side view of SingleProducerAsyncInput for variance purposes.

Signature

export interface AsyncInputConsumer<out Err, out Elem, out Done> {
  takeWith<A>(
    onError: (cause: Cause.Cause<Err>) => A,
    onElement: (element: Elem) => A,
    onDone: (value: Done) => A
  ): Effect.Effect<A>
}

Source

Since v2.0.0