|
50 | 50 | import java.util.Map;
|
51 | 51 | import java.util.concurrent.Semaphore;
|
52 | 52 | import java.util.concurrent.atomic.AtomicReference;
|
53 |
| - |
54 | 53 | import org.junit.After;
|
55 | 54 | import org.junit.Test;
|
56 | 55 | import org.junit.runner.RunWith;
|
@@ -1092,11 +1091,11 @@ public void resumingAQueryShouldUseBloomFilterToAvoidFullRequery() throws Except
|
1092 | 1091 | // bloom filter, and it was used to avert a full requery.
|
1093 | 1092 | AtomicReference<QuerySnapshot> snapshot2Ref = new AtomicReference<>();
|
1094 | 1093 | ArrayList<ExistenceFilterMismatchInfo> existenceFilterMismatches =
|
1095 |
| - captureExistenceFilterMismatches( |
1096 |
| - () -> { |
1097 |
| - QuerySnapshot querySnapshot = waitFor(collection.get()); |
1098 |
| - snapshot2Ref.set(querySnapshot); |
1099 |
| - }); |
| 1094 | + captureExistenceFilterMismatches( |
| 1095 | + () -> { |
| 1096 | + QuerySnapshot querySnapshot = waitFor(collection.get()); |
| 1097 | + snapshot2Ref.set(querySnapshot); |
| 1098 | + }); |
1100 | 1099 | QuerySnapshot snapshot2 = snapshot2Ref.get();
|
1101 | 1100 |
|
1102 | 1101 | // Verify that the snapshot from the resumed query contains the expected documents; that is,
|
@@ -1132,8 +1131,8 @@ public void resumingAQueryShouldUseBloomFilterToAvoidFullRequery() throws Except
|
1132 | 1131 | // Verify that Watch sent an existence filter with the correct counts when the query was
|
1133 | 1132 | // resumed.
|
1134 | 1133 | assertWithMessage("Watch should have sent exactly 1 existence filter")
|
1135 |
| - .that(existenceFilterMismatches) |
1136 |
| - .hasSize(1); |
| 1134 | + .that(existenceFilterMismatches) |
| 1135 | + .hasSize(1); |
1137 | 1136 | ExistenceFilterMismatchInfo existenceFilterMismatchInfo = existenceFilterMismatches.get(0);
|
1138 | 1137 | assertWithMessage("localCacheCount")
|
1139 | 1138 | .that(existenceFilterMismatchInfo.localCacheCount())
|
|
0 commit comments