MCPcopy Index your code
hub / github.com/Effect-TS/effect / onInterruptSignal

Function onInterruptSignal

packages/effect/src/internal/fiberRuntime.ts:2256–2263  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

2254 return fiber
2255 }
2256 const onInterruptSignal = () => {
2257 if (!processAll) {
2258 target -= todos.length
2259 todos = []
2260 }
2261 interrupted = true
2262 interruptAll()
2263 }
2264 const stepOrExit = batching ? core.step : core.exit
2265 const processingFiber = runFiber(
2266 core.async<any, any, any>((resume) => {

Callers 2

pushResultFunction · 0.85
forEachConcurrentDiscardFunction · 0.85

Calls 1

interruptAllFunction · 0.70

Tested by

no test coverage detected