(key: Key)
| 92 | }) |
| 93 | |
| 94 | const interrupt = (key: Key): Effect.Effect<void> => |
| 95 | Effect.suspend(() => { |
| 96 | const entry = active.get(key) |
| 97 | if (entry?.owner === undefined) return Effect.void |
| 98 | entry.stopping = true |
| 99 | entry.pendingWake = false |
| 100 | return Fiber.interrupt(entry.owner) |
| 101 | }) |
| 102 | |
| 103 | return { active: Effect.sync(() => new Set(active.keys())), run, wake, interrupt } |
| 104 | }) |
no test coverage detected