Function awaiter

packages/effect/src/Queue.ts:1573–1573

(effect: Effect<void, E>)

const await_ = <A, E>(self: Dequeue<A, E>): Effect<void, Exclude<E, Done>> =>
  internalEffect.callback<void, Exclude<E, Done>>((resume) => {
    const awaiter = (effect: Effect<void, E>) => resume(Pull.catchDone(effect, () => internalEffect.exitVoid))
    if (self.state._tag === "Done") {
      return awaiter(self.state.exit)
    }