effect-io-ai

Package: effect
Module: SingleProducerAsyncInput

SingleProducerAsyncInput.AsyncInputProducer

Producer-side view of SingleProducerAsyncInput for variance purposes.

Signature

export interface AsyncInputProducer<in Err, in Elem, in Done> {
  awaitRead(): Effect.Effect<unknown>
  done(value: Done): Effect.Effect<unknown>
  emit(element: Elem): Effect.Effect<unknown>
  error(cause: Cause.Cause<Err>): Effect.Effect<unknown>
}

Source

Since v2.0.0