(
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>
)
| 1588 | const pullR = yield* toPullIn(core.pipeTo(queueReader, options.other), scope) |
| 1589 | |
| 1590 | function handleSide<Err, Done, Err2, Done2>( |
| 1591 | exit: Exit.Exit<Either.Either<OutElem | OutElem1, Done>, Err>, |
| 1592 | fiber: Fiber.Fiber<Either.Either<OutElem | OutElem1, Done2>, Err2>, |
| 1593 | pull: Effect.Effect<Either.Either<OutElem | OutElem1, Done>, Err, Env | Env1> |
| 1594 | ) { |
| 1595 | return ( |
| 1596 | done: ( |
| 1597 | ex: Exit.Exit<Done, Err> |
| 1598 | ) => MergeDecision.MergeDecision< |
| 1599 | Env | Env1, |
| 1600 | Err2, |
| 1601 | Done2, |
| 1602 | OutErr2 | OutErr3, |
| 1603 | OutDone2 | OutDone3 |
| 1604 | >, |
| 1605 | both: ( |
| 1606 | f1: Fiber.Fiber<Either.Either<OutElem | OutElem1, Done>, Err>, |
| 1607 | f2: Fiber.Fiber<Either.Either<OutElem | OutElem1, Done2>, Err2> |
| 1608 | ) => State, |
| 1609 | single: ( |
| 1610 | f: ( |
| 1611 | ex: Exit.Exit<Done2, Err2> |
| 1612 | ) => Effect.Effect<OutDone2 | OutDone3, OutErr2 | OutErr3, Env | Env1> |
| 1613 | ) => State |
| 1614 | ): Effect.Effect< |
| 1615 | Channel.Channel< |
| 1616 | OutElem | OutElem1, |
| 1617 | unknown, |
| 1618 | OutErr2 | OutErr3, |
| 1619 | unknown, |
| 1620 | OutDone2 | OutDone3, |
| 1621 | unknown, |
| 1622 | Env | Env1 |
| 1623 | >, |
| 1624 | never, |
| 1625 | Env | Env1 |
| 1626 | > => { |
| 1627 | function onDecision( |
| 1628 | decision: MergeDecision.MergeDecision< |
| 1629 | Env | Env1, |
| 1630 | Err2, |
| 1631 | Done2, |
| 1632 | OutErr2 | OutErr3, |
| 1633 | OutDone2 | OutDone3 |
| 1634 | > |
| 1635 | ): Effect.Effect< |
| 1636 | Channel.Channel< |
| 1637 | OutElem | OutElem1, |
| 1638 | unknown, |
| 1639 | OutErr2 | OutErr3, |
| 1640 | unknown, |
| 1641 | OutDone2 | OutDone3, |
| 1642 | unknown, |
| 1643 | Env | Env1 |
| 1644 | > |
| 1645 | > { |
| 1646 | const op = decision as mergeDecision.Primitive |
| 1647 | if (op._tag === MergeDecisionOpCodes.OP_DONE) { |
no test coverage detected