@internal
(observer: QueryObserver<any, any, any, any, any>)
| 509 | |
| 510 | /** @internal */ |
| 511 | addObserver(observer: QueryObserver<any, any, any, any, any>): void { |
| 512 | if (!this.observers.includes(observer)) { |
| 513 | this.observers.push(observer) |
| 514 | |
| 515 | // Stop the query from being garbage collected |
| 516 | this.clearGcTimeout() |
| 517 | |
| 518 | this.#cache.notify({ type: 'observerAdded', query: this, observer }) |
| 519 | } |
| 520 | } |
| 521 | |
| 522 | /** @internal */ |
| 523 | removeObserver(observer: QueryObserver<any, any, any, any, any>): void { |
no test coverage detected