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

Function pushResult

packages/effect/src/internal/fiberRuntime.ts:2267–2276  ·  view source on GitHub ↗
(res: Exit.Exit<X, E> | Effect.Blocked<X, E>, index: number)

Source from the content-addressed store, hash-verified

2265 const processingFiber = runFiber(
2266 core.async<any, any, any>((resume) => {
2267 const pushResult = <X, E>(res: Exit.Exit<X, E> | Effect.Blocked<X, E>, index: number) => {
2268 if (res._op === "Blocked") {
2269 residual.push(res as core.Blocked)
2270 } else {
2271 results.push({ index, exit: res })
2272 if (res._op === "Failure" && !interrupted) {
2273 onInterruptSignal()
2274 }
2275 }
2276 }
2277 const next = () => {
2278 if (todos.length > 0) {
2279 const a = todos.pop()!

Callers 2

onResFunction · 0.85
nextFunction · 0.85

Calls 1

onInterruptSignalFunction · 0.85

Tested by

no test coverage detected