Function evaluatePull

packages/effect/src/internal/channel.ts:1138–1173

(
          pull: Effect.Effect<
            Either.Either<OutElem, OutDone>,
            OutErr | OutErr1,
            Env | Env1
          >
        )

        const pull = yield* toPullIn(core.pipeTo(queueReader, channels), scope)

        function evaluatePull(
          pull: Effect.Effect<
            Either.Either<OutElem, OutDone>,
            OutErr | OutErr1,
            Env | Env1
          >
        ) {
          return pull.pipe(
            Effect.flatMap(Either.match({
              onLeft: (done) => Effect.succeed(Option.some(done)),
              onRight: (outElem) =>
                Effect.as(
                  Queue.offer(queue, Effect.succeed(Either.right(outElem))),
                  Option.none()
                )
            })),
            Effect.repeat({ until: (_): _ is Option.Some<OutDone> => Option.isSome(_) }),
            Effect.flatMap((outDone) =>
              Ref.update(
                lastDone,
                Option.match({
                  onNone: () => Option.some(outDone.value),
                  onSome: (lastDone) => Option.some(f(lastDone, outDone.value))
                })
              )
            ),
            Effect.catchAllCause((cause) =>
              Cause.isInterrupted(cause)
                ? Effect.failCause(cause)
                : Queue.offer(queue, Effect.failCause(cause)).pipe(
                  Effect.zipRight(Deferred.succeed(errorSignal, void 0)),
                  Effect.asVoid
                )
            )
          )
        }

        yield* pull.pipe(
          Effect.matchCauseEffect({