()
| 340 | } |
| 341 | |
| 342 | onOnline(): void { |
| 343 | const observer = this.observers.find((x) => x.shouldFetchOnReconnect()) |
| 344 | |
| 345 | observer?.refetch({ cancelRefetch: false }) |
| 346 | |
| 347 | // Continue fetch if currently paused |
| 348 | this.#retryer?.continue() |
| 349 | } |
| 350 | |
| 351 | addObserver(observer: QueryObserver<any, any, any, any, any>): void { |
| 352 | if (!this.observers.includes(observer)) { |
no test coverage detected