(exit: Exit.Exit<OutElem2, EX>)
| 2183 | |
| 2184 | let errorCause: Cause.Cause<EX> | undefined |
| 2185 | const onExit = (exit: Exit.Exit<OutElem2, EX>) => { |
| 2186 | if (exit._tag === "Success") return |
| 2187 | errorCause = exit.cause |
| 2188 | Queue.failCauseUnsafe(queue, exit.cause) |
| 2189 | } |
| 2190 | yield* pull.pipe( |
| 2191 | Effect.flatMap((value) => { |
| 2192 | if (errorCause) return Effect.failCause(errorCause) |
no outgoing calls
no test coverage detected