@Test public void testResumeTokenHandledPerTarget() { Map<Integer, TargetData> targetMap = activeQueries(1, 2); WatchChangeAggregator aggregator = createAggregator(targetMap, noOutstandingResponses, noExistingKeys); WatchTargetChange change1 = new WatchTargetChange(WatchTargetChangeType.Current, asList(1)); aggregator.handleTargetChange(change1); ByteString resumeToken2 = ByteString.copyFromUtf8("resumeToken2"); WatchTargetChange change2 = new WatchTargetChange(WatchTargetChangeType.Current, asList(2), resumeToken2); aggregator.handleTargetChange(change2); RemoteEvent event = aggregator.createRemoteEvent(version(3)); assertEquals(2, event.getTargetChanges().size()); TargetChange mapping1 = targetChange(resumeToken, true, null, null, null); assertEquals(mapping1, event.getTargetChanges().get(1)); TargetChange mapping2 = targetChange(resumeToken2, true, null, null, null); assertEquals(mapping2, event.getTargetChanges().get(2)); }
public Map<Integer, TargetChange> getTargetChanges() { return targetChanges; }
RemoteEvent { public Map<Integer, TargetChange> getTargetChanges() { return targetChanges; } }
RemoteEvent { public Map<Integer, TargetChange> getTargetChanges() { return targetChanges; } RemoteEvent(
      SnapshotVersion snapshotVersion,
      Map<Integer, TargetChange> targetChanges,
      Set<Integer> targetMismatches,
      Map<DocumentKey, MaybeDocument> documentUpdates,
      Set<DocumentKey> resolvedLimboDocuments); }
RemoteEvent { public Map<Integer, TargetChange> getTargetChanges() { return targetChanges; } RemoteEvent(
      SnapshotVersion snapshotVersion,
      Map<Integer, TargetChange> targetChanges,
      Set<Integer> targetMismatches,
      Map<DocumentKey, MaybeDocument> documentUpdates,
      Set<DocumentKey> resolvedLimboDocuments); SnapshotVersion getSnapshotVersion(); Map<Integer, TargetChange> getTargetChanges(); Set<Integer> getTargetMismatches(); Map<DocumentKey, MaybeDocument> getDocumentUpdates(); Set<DocumentKey> getResolvedLimboDocuments(); @Override String toString(); }
RemoteEvent { public Map<Integer, TargetChange> getTargetChanges() { return targetChanges; } RemoteEvent(
      SnapshotVersion snapshotVersion,
      Map<Integer, TargetChange> targetChanges,
      Set<Integer> targetMismatches,
      Map<DocumentKey, MaybeDocument> documentUpdates,
      Set<DocumentKey> resolvedLimboDocuments); SnapshotVersion getSnapshotVersion(); Map<Integer, TargetChange> getTargetChanges(); Set<Integer> getTargetMismatches(); Map<DocumentKey, MaybeDocument> getDocumentUpdates(); Set<DocumentKey> getResolvedLimboDocuments(); @Override String toString();  }