(self: Effect.Effect<A, E, R>)
| 3548 | |
| 3549 | /** @internal */ |
| 3550 | export const disconnect = <A, E, R>(self: Effect.Effect<A, E, R>): Effect.Effect<A, E, R> => |
| 3551 | core.uninterruptibleMask((restore) => |
| 3552 | core.fiberIdWith((fiberId) => |
| 3553 | core.flatMap(forkDaemon(restore(self)), (fiber) => |
| 3554 | pipe( |
| 3555 | restore(internalFiber.join(fiber)), |
| 3556 | core.onInterrupt(() => pipe(fiber, internalFiber.interruptAsFork(fiberId))) |
| 3557 | )) |
| 3558 | ) |
| 3559 | ) |
| 3560 | |
| 3561 | /** @internal */ |
| 3562 | export const race = dual< |
nothing calls this directly
no test coverage detected