(
register: (
this: Scheduler.Scheduler,
resume: (effect: Effect.Effect<A, E, R>) => void,
signal: AbortSignal
) => void | Effect.Effect<void, never, R>
)
| 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) { |
no outgoing calls
no test coverage detected
searching dependent graphs…