Function merge

packages/effect/src/internal/channel.ts:1568–1819

(scope: Scope.Scope)

  Env1 | Env
> => {
  function merge(scope: Scope.Scope) {
    return Effect.gen(function*() {
      type State = MergeState.MergeState<
        Env | Env1,
        OutErr,
        OutErr1,
        OutErr2 | OutErr3,
        OutElem | OutElem1,
        OutDone,
        OutDone1,
        OutDone2 | OutDone3
      >

      const input = yield* singleProducerAsyncInput.make<
        InErr & InErr1,
        InElem & InElem1,
        InDone & InDone1
      >()
      const queueReader = fromInput(input)
      const pullL = yield* toPullIn(core.pipeTo(queueReader, self), scope)
      const pullR = yield* toPullIn(core.pipeTo(queueReader, options.other), scope)

      function handleSide<Err, Done, Err2, Done2>(
        exit: Exit.Exit<Either.Either<OutElem | OutElem1, Done>, Err>,
        fiber: Fiber.Fiber<Either.Either<OutElem | OutElem1, Done2>, Err2>,
        pull: Effect.Effect<Either.Either<OutElem | OutElem1, Done>, Err, Env | Env1>
      ) {
        return (
          done: (
            ex: Exit.Exit<Done, Err>
          ) => MergeDecision.MergeDecision<
            Env | Env1,
            Err2,
            Done2,
            OutErr2 | OutErr3,
            OutDone2 | OutDone3
          >,
          both: (
            f1: Fiber.Fiber<Either.Either<OutElem | OutElem1, Done>, Err>,
            f2: Fiber.Fiber<Either.Either<OutElem | OutElem1, Done2>, Err2>
          ) => State,
          single: (
            f: (
              ex: Exit.Exit<Done2, Err2>
            ) => Effect.Effect<OutDone2 | OutDone3, OutErr2 | OutErr3, Env | Env1>
          ) => State
        ): Effect.Effect<
          Channel.Channel<
            OutElem | OutElem1,
            unknown,
            OutErr2 | OutErr3,
            unknown,
            OutDone2 | OutDone3,
            unknown,
            Env | Env1
          >,
          never,
          Env | Env1