MCPcopy Create free account
hub / github.com/Effect-TS/effect / resume

Function resume

packages/effect/src/unstable/rpc/RpcClient.ts:398–405  ·  view source on GitHub ↗
(exit)

Source from the content-addressed store, hash-verified

396 rpc,
397 context,
398 resume(exit) {
399 resume(exit)
400 if (fiber && !fiber.pollUnsafe()) {
401 parentFiber.currentDispatcher.scheduleTask(() => {
402 fiber.interruptUnsafe(parentFiber.id)
403 }, 0)
404 }
405 }
406 }
407 entries.set(id, entry)
408 fiber = send.pipe(

Callers 15

onEffectRequestFunction · 0.70
sendInterruptFunction · 0.70
runRawMethod · 0.50
makeFunction · 0.50
makeFunction · 0.50
runFunction · 0.50
runProcedureFunction · 0.50
onErrorFunction · 0.50
makeConectionFunction · 0.50
PgClient.tsFile · 0.50

Calls 3

pollUnsafeMethod · 0.80
interruptUnsafeMethod · 0.80
scheduleTaskMethod · 0.65

Tested by 6

idbRequestFunction · 0.40
assertOpenResultFunction · 0.40
openWebSocketFunction · 0.40
connectWebSocketFunction · 0.40
assertOpenResultFunction · 0.40
connectFunction · 0.40