(fn: Listener)
| 97 | } |
| 98 | |
| 99 | subscribe(fn: Listener): () => void { |
| 100 | this.listeners.add(fn); |
| 101 | fn(this.stream); |
| 102 | return () => this.listeners.delete(fn); |
| 103 | } |
| 104 | |
| 105 | private update(partial: Partial<TrackerStreamState>): void { |
| 106 | this.stream = { ...this.stream, ...partial }; |