utils

export interface Emitter<in A, in E> {
  readonly succeed: (value: A) => Promise<Exit.Exit<unknown>>
  readonly failCause: (cause: Cause.Cause<E>) => Promise<Exit.Exit<unknown>>
  readonly fail: (error: E) => Promise<Exit.Exit<unknown>>
  readonly die: (error: unknown) => Promise<Exit.Exit<unknown>>
  readonly end: () => Promise<Exit.Exit<unknown>>
}

export declare function withEmitter<A, E, R, R2, B>(
  sink: Sink.Sink<A, E, R>,
  f: (emitter: Emitter<A, E>) => Effect.Effect<B, E, R2>
): Effect.Effect<void, never, R | R2 | Scope.Scope>