* Polls until all descendants of this fiber are done or suspended.
()
| 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. |
no test coverage detected