* Adds a message to be processed by the fiber on the fiber.
(message: FiberMessage.FiberMessage)
| 441 | * Adds a message to be processed by the fiber on the fiber. |
| 442 | */ |
| 443 | tell(message: FiberMessage.FiberMessage): void { |
| 444 | this._queue.push(message) |
| 445 | if (!this._running) { |
| 446 | this._running = true |
| 447 | this.drainQueueLaterOnExecutor() |
| 448 | } |
| 449 | } |
| 450 | |
| 451 | get await(): Effect.Effect<Exit.Exit<A, E>> { |
| 452 | return core.async((resume) => { |
no test coverage detected