(observer: QueryObserver<any, any, any, any, any>)
| 347 | } |
| 348 | |
| 349 | addObserver(observer: QueryObserver<any, any, any, any, any>): void { |
| 350 | if (!this.observers.includes(observer)) { |
| 351 | this.observers.push(observer) |
| 352 | |
| 353 | // Stop the query from being garbage collected |
| 354 | this.clearGcTimeout() |
| 355 | |
| 356 | this.#cache.notify({ type: 'observerAdded', query: this, observer }) |
| 357 | } |
| 358 | } |
| 359 | |
| 360 | removeObserver(observer: QueryObserver<any, any, any, any, any>): void { |
| 361 | const index = this.observers.indexOf(observer) |
no test coverage detected