@@ -416,14 +416,17 @@ public QueryData getQueryDataForTarget(int targetId) {
416
416
417
417
public static RemoteEvent updateRemoteEvent (
418
418
MaybeDocument doc , List <Integer > updatedInTargets , List <Integer > removedFromTargets ) {
419
- return updateRemoteEvent (doc , updatedInTargets , removedFromTargets , Collections .emptyList ());
419
+ List <Integer > activeTargets = new ArrayList <>();
420
+ activeTargets .addAll (updatedInTargets );
421
+ activeTargets .addAll (removedFromTargets );
422
+ return updateRemoteEvent (doc , updatedInTargets , removedFromTargets , activeTargets );
420
423
}
421
424
422
425
public static RemoteEvent updateRemoteEvent (
423
426
MaybeDocument doc ,
424
427
List <Integer > updatedInTargets ,
425
428
List <Integer > removedFromTargets ,
426
- List <Integer > limboTargets ) {
429
+ List <Integer > activeTargets ) {
427
430
DocumentChange change =
428
431
new DocumentChange (updatedInTargets , removedFromTargets , doc .getKey (), doc );
429
432
WatchChangeAggregator aggregator =
@@ -436,11 +439,9 @@ public ImmutableSortedSet<DocumentKey> getRemoteKeysForTarget(int targetId) {
436
439
437
440
@ Override
438
441
public QueryData getQueryDataForTarget (int targetId ) {
439
- boolean isLimbo =
440
- !(updatedInTargets .contains (targetId ) || removedFromTargets .contains (targetId ));
441
- QueryPurpose purpose =
442
- isLimbo ? QueryPurpose .LIMBO_RESOLUTION : QueryPurpose .LISTEN ;
443
- return queryData (targetId , purpose , doc .getKey ().toString ());
442
+ return activeTargets .contains (targetId )
443
+ ? queryData (targetId , QueryPurpose .LISTEN , doc .getKey ().toString ())
444
+ : null ;
444
445
}
445
446
});
446
447
aggregator .handleDocumentChange (change );
0 commit comments