(cb: (exit: MicroExit<A, E>) => void)
| 482 | } |
| 483 | |
| 484 | addObserver(cb: (exit: MicroExit<A, E>) => void): () => void { |
| 485 | if (this._exit) { |
| 486 | cb(this._exit) |
| 487 | return constVoid |
| 488 | } |
| 489 | this._observers.push(cb) |
| 490 | return () => { |
| 491 | const index = this._observers.indexOf(cb) |
| 492 | if (index >= 0) { |
| 493 | this._observers.splice(index, 1) |
| 494 | } |
| 495 | } |
| 496 | } |
| 497 | |
| 498 | _interrupted = false |
| 499 | unsafeInterrupt(): void { |
no outgoing calls
no test coverage detected