()
| 63 | } |
| 64 | |
| 65 | protected onSubscribe(): void { |
| 66 | if (this.listeners.size === 1) { |
| 67 | this.#observers.forEach((observer) => { |
| 68 | observer.subscribe((result) => { |
| 69 | this.#onUpdate(observer, result) |
| 70 | }) |
| 71 | }) |
| 72 | } |
| 73 | } |
| 74 | |
| 75 | protected onUnsubscribe(): void { |
| 76 | if (!this.listeners.size) { |