models

export interface Emit<in R, in E, in A, out B> extends EmitOps<R, E, A, B> {
  (f: Effect.Effect<Chunk.Chunk<A>, Option.Option<E>, R>): Promise<B>
}

export interface EmitOps<in R, in E, in A, out B> {
  /**
   * Emits a chunk containing the specified values.
   */
  chunk(chunk: Chunk.Chunk<A>): Promise<B>

  /**
   * Terminates with a cause that dies with the specified defect.
   */
  die<Err>(defect: Err): Promise<B>

  /**
   * Terminates with a cause that dies with a `Throwable` with the specified
   * message.
   */
  dieMessage(message: string): Promise<B>

  /**
   * Either emits the specified value if this `Exit` is a `Success` or else
   * terminates with the specified cause if this `Exit` is a `Failure`.
   */
  done(exit: Exit.Exit<A, E>): Promise<B>

  /**
   * Terminates with an end of stream signal.
   */
  end(): Promise<B>

  /**
   * Terminates with the specified error.
   */
  fail(error: E): Promise<B>

  /**
   * Either emits the success value of this effect or terminates the stream
   * with the failure value of this effect.
   */
  fromEffect(effect: Effect.Effect<A, E, R>): Promise<B>

  /**
   * Either emits the success value of this effect or terminates the stream
   * with the failure value of this effect.
   */
  fromEffectChunk(effect: Effect.Effect<Chunk.Chunk<A>, E, R>): Promise<B>

  /**
   * Terminates the stream with the specified cause.
   */
  halt(cause: Cause.Cause<E>): Promise<B>

  /**
   * Emits a chunk containing the specified value.
   */
  single(value: A): Promise<B>
}