(cb: (exit: Exit.Exit<A, E>) => void)
| 550 | currentPreventYield!: boolean |
| 551 | |
| 552 | _dispatcher: Scheduler.SchedulerDispatcher | undefined = undefined |
| 553 | get currentDispatcher(): Scheduler.SchedulerDispatcher { |
| 554 | return this._dispatcher ??= this.currentScheduler.makeDispatcher() |
| 555 | } |
| 556 | |
| 557 | getRef<X>(ref: Context.Reference<X>): X { |
| 558 | return Context.get(this.context, ref) |
| 559 | } |
| 560 | addObserver(cb: (exit: Exit.Exit<A, E>) => void): () => void { |
| 561 | if (this._exit) { |
| 562 | cb(this._exit) |
| 563 | return constVoid |
| 564 | } |
| 565 | this._observers.push(cb) |
| 566 | return () => { |
| 567 | const index = this._observers.indexOf(cb) |
no test coverage detected