Method shutdown

packages/effect/src/internal/queue.ts:544–567

()

  }

  get shutdown(): Effect.Effect<void> {
    return pipe(
      core.fiberId,
      core.flatMap((fiberId) =>
        pipe(
          core.sync(() => unsafePollAll(this.putters)),
          core.flatMap((putters) =>
            fiberRuntime.forEachConcurrentDiscard(
              putters,
              ([_, deferred, isLastItem]) =>
                isLastItem ?
                  pipe(
                    core.deferredInterruptWith(deferred, fiberId),
                    core.asVoid
                  ) :
                  core.void,
              false,
              false
            )
          )
        )
      )
    )
  }

  handleSurplus(
    iterable: Iterable<A>,