83
83
import org .junit .After ;
84
84
import org .junit .Assert ;
85
85
import org .junit .Before ;
86
- import org .junit .Ignore ;
87
86
import org .junit .Test ;
88
87
89
88
/**
@@ -154,7 +153,8 @@ private void udpateViews(int targetId, boolean fromCache) {
154
153
notifyLocalViewChanges (viewChanges (targetId , fromCache , asList (), asList ()));
155
154
}
156
155
157
- private void acknowledgeMutationWithTransform (long documentVersion , Object ... transformResult ) {
156
+ private void acknowledgeMutationWithTransformResults (
157
+ long documentVersion , Object ... transformResult ) {
158
158
MutationBatch batch = batches .remove (0 );
159
159
SnapshotVersion version = version (documentVersion );
160
160
List <MutationResult > mutationResults =
@@ -172,7 +172,7 @@ private void acknowledgeMutationWithTransform(long documentVersion, Object... tr
172
172
}
173
173
174
174
private void acknowledgeMutation (long documentVersion ) {
175
- acknowledgeMutationWithTransform (documentVersion , null );
175
+ acknowledgeMutationWithTransformResults (documentVersion , null );
176
176
}
177
177
178
178
private void rejectMutation () {
@@ -1074,7 +1074,7 @@ public void testHandlesSetMutationThenAckThenTransformThenAckThenTransform() {
1074
1074
assertContains (doc ("foo/bar" , 1 , map ("sum" , 1 )).setHasLocalMutations ());
1075
1075
assertChanged (doc ("foo/bar" , 1 , map ("sum" , 1 )).setHasLocalMutations ());
1076
1076
1077
- acknowledgeMutationWithTransform (2 , 1 );
1077
+ acknowledgeMutationWithTransformResults (2 , 1 );
1078
1078
assertChanged (doc ("foo/bar" , 2 , map ("sum" , 1 )).setHasCommittedMutations ());
1079
1079
assertContains (doc ("foo/bar" , 2 , map ("sum" , 1 )).setHasCommittedMutations ());
1080
1080
@@ -1288,11 +1288,11 @@ public void testHandlesSetMutationThenTransformThenRemoteEventThenTransform() {
1288
1288
assertChanged (doc ("foo/bar" , 2 , map ("sum" , 3 )).setHasLocalMutations ());
1289
1289
assertContains (doc ("foo/bar" , 2 , map ("sum" , 3 )).setHasLocalMutations ());
1290
1290
1291
- acknowledgeMutationWithTransform (3 , 1 );
1291
+ acknowledgeMutationWithTransformResults (3 , 1 );
1292
1292
assertChanged (doc ("foo/bar" , 3 , map ("sum" , 3 )).setHasLocalMutations ());
1293
1293
assertContains (doc ("foo/bar" , 3 , map ("sum" , 3 )).setHasLocalMutations ());
1294
1294
1295
- acknowledgeMutationWithTransform (4 , 1339 );
1295
+ acknowledgeMutationWithTransformResults (4 , 1339 );
1296
1296
assertChanged (doc ("foo/bar" , 4 , map ("sum" , 1339 )).setHasCommittedMutations ());
1297
1297
assertContains (doc ("foo/bar" , 4 , map ("sum" , 1339 )).setHasCommittedMutations ());
1298
1298
}
@@ -1337,7 +1337,7 @@ public void testHoldsBackTransforms() {
1337
1337
assertChanged (
1338
1338
doc ("foo/bar" , 2 , map ("sum" , 1 , "array_union" , asList ("foo" ))).setHasLocalMutations ());
1339
1339
1340
- acknowledgeMutationWithTransform (3 , 1338 , asList ("bar" , "foo" ));
1340
+ acknowledgeMutationWithTransformResults (3 , 1338 , asList ("bar" , "foo" ));
1341
1341
assertChanged (
1342
1342
doc ("foo/bar" , 3 , map ("sum" , 1338 , "array_union" , asList ("bar" , "foo" )))
1343
1343
.withReadTime (new SnapshotVersion (new Timestamp (0 , 3000 )))
0 commit comments