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

Method awaitSuspended

packages/effect/src/TestClock.ts:334–350  ·  view source on GitHub ↗

* Polls until all descendants of this fiber are done or suspended.

()

Source from the content-addressed store, hash-verified

332 * Polls until all descendants of this fiber are done or suspended.
333 */
334 awaitSuspended(): Effect.Effect<void> {
335 return pipe(
336 this.suspendedWarningStart(),
337 core.zipRight(
338 pipe(
339 this.suspended(),
340 core.zipWith(
341 pipe(this.yieldTimer, core.zipRight(this.suspended())),
342 Equal.equals
343 ),
344 effect.filterOrFail(identity, constVoid),
345 effect.eventually
346 )
347 ),
348 core.zipRight(this.suspendedWarningDone())
349 )
350 }
351 /**
352 * Forks a fiber that will display a warning message if a test is advancing
353 * the `TestClock` but a fiber is not suspending.

Callers 1

runMethod · 0.95

Calls 4

suspendedWarningStartMethod · 0.95
suspendedMethod · 0.95
suspendedWarningDoneMethod · 0.95
pipeFunction · 0.70

Tested by

no test coverage detected