MCPcopy Create free account
hub / github.com/effect-app/libs / callback

Function callback

repos/effect/packages/effect/src/internal/effect.ts:1101–1107  ·  view source on GitHub ↗
(
  register: (
    this: Scheduler.Scheduler,
    resume: (effect: Effect.Effect<A, E, R>) => void,
    signal: AbortSignal
  ) => void | Effect.Effect<void, never, R>
)

Source from the content-addressed store, hash-verified

1099) => Effect.Effect<A, E, R> = makePrimitive({
1100 op: "Async",
1101 single: false,
1102 [evaluate](fiber) {
1103 const register = internalCall(() => this[args][0].bind(fiber.currentScheduler))
1104 let resumed = false
1105 let yielded: boolean | Primitive = false
1106 const controller = this[args][1] ? new AbortController() : undefined
1107 const onCancel = register((effect) => {
1108 if (resumed) return
1109 resumed = true
1110 if (yielded) {

Callers 9

fiberAwaitFunction · 0.70
fiberAwaitAllFunction · 0.70
fiberJoinFunction · 0.70
fiberJoinAllFunction · 0.70
effect.tsFile · 0.70
raceAllFunction · 0.70
raceAllFirstFunction · 0.70
LatchClass · 0.70
sleepMethod · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…