(self: Fiber.Fiber<A, E>)
| 811 | |
| 812 | /** @internal */ |
| 813 | export const fiberJoin = <A, E>(self: Fiber.Fiber<A, E>): Effect.Effect<A, E> => { |
| 814 | const impl = self as FiberImpl<A, E> |
| 815 | if (impl._exit) return impl._exit |
| 816 | return callback((resume) => { |
| 817 | if (impl._exit) return resume(impl._exit) |
| 818 | return sync(self.addObserver(resume)) |
| 819 | }) |
| 820 | } |
| 821 | |
| 822 | /** @internal */ |
| 823 | export const fiberJoinAll = <A extends Iterable<Fiber.Fiber<any, any>>>(self: A): Effect.Effect< |
nothing calls this directly
no test coverage detected