Class Emit

packages/effect/src/internal/channel/subexecutor.ts:215–229

/** @internal */
export class Emit<in out R> implements Subexecutor<R> {
  readonly _tag: OP_EMIT = OP_EMIT

  constructor(readonly value: unknown, readonly next: Subexecutor<R>) {
  }

  close(exit: Exit.Exit<unknown, unknown>): Effect.Effect<unknown, never, R> | undefined {
    const result = this.next.close(exit)
    return result === undefined ? result : result
  }

  enqueuePullFromChild(_child: PullFromChild<R>): Subexecutor<R> {
    return this
  }
}