MCPcopy
hub / github.com/Effect-TS/effect / asyncInterrupt

Function asyncInterrupt

packages/effect/src/internal/core.ts:505–510  ·  view source on GitHub ↗
(
  register: (
    callback: (_: Effect.Effect<A, E, R>) => void
  ) => void | Effect.Effect<void, never, R>,
  blockingOn: FiberId.FiberId = FiberId.none
)

Source from the content-addressed store, hash-verified

503
504/* @internal */
505export const asyncInterrupt = <A, E = never, R = never>(
506 register: (
507 callback: (_: Effect.Effect<A, E, R>) => void
508 ) => void | Effect.Effect<void, never, R>,
509 blockingOn: FiberId.FiberId = FiberId.none
510): Effect.Effect<A, E, R> => suspend(() => unsafeAsync(register, blockingOn))
511
512const async_ = <A, E = never, R = never>(
513 resume: (

Callers 2

core.tsFile · 0.85
deferredAwaitFunction · 0.85

Calls 2

unsafeAsyncFunction · 0.85
suspendFunction · 0.70

Tested by

no test coverage detected