(changes: Array<ChangeMessage<any, any>>)
| 319 | } |
| 320 | |
| 321 | emitEvents(changes: Array<ChangeMessage<any, any>>) { |
| 322 | const newChanges = this.filterAndFlipChanges(changes) |
| 323 | |
| 324 | if (this.isBufferingForTruncate) { |
| 325 | // Buffer the changes instead of emitting immediately |
| 326 | // This prevents a flash of missing content during truncate/refetch |
| 327 | if (newChanges.length > 0) { |
| 328 | this.truncateBuffer.push(newChanges) |
| 329 | } |
| 330 | } else { |
| 331 | this.filteredCallback(newChanges) |
| 332 | } |
| 333 | } |
| 334 | |
| 335 | /** |
| 336 | * Sends the snapshot to the callback. |
nothing calls this directly
no test coverage detected