@@ -67,7 +67,7 @@ public void testLimitQueries() {
67
67
68
68
Query query = collection .limit (2 );
69
69
FirebaseFirestore db = collection .firestore ;
70
- PipelineSnapshot set = waitFor (db .pipeline ().createFrom (query ).execute ());
70
+ Pipeline . Snapshot set = waitFor (db .pipeline ().createFrom (query ).execute ());
71
71
List <Map <String , Object >> data = pipelineSnapshotToValues (set );
72
72
assertEquals (asList (map ("k" , "a" ), map ("k" , "b" )), data );
73
73
}
@@ -84,7 +84,7 @@ public void testLimitQueriesUsingDescendingSortOrder() {
84
84
85
85
Query query = collection .limit (2 ).orderBy ("sort" , Direction .DESCENDING );
86
86
FirebaseFirestore db = collection .firestore ;
87
- PipelineSnapshot set = waitFor (db .pipeline ().createFrom (query ).execute ());
87
+ Pipeline . Snapshot set = waitFor (db .pipeline ().createFrom (query ).execute ());
88
88
89
89
List <Map <String , Object >> data = pipelineSnapshotToValues (set );
90
90
assertEquals (asList (map ("k" , "d" , "sort" , 2L ), map ("k" , "c" , "sort" , 1L )), data );
@@ -114,7 +114,7 @@ public void testLimitToLastQueriesWithCursors() {
114
114
Query query = collection .limitToLast (3 ).orderBy ("sort" ).endBefore (2 );
115
115
FirebaseFirestore db = collection .firestore ;
116
116
117
- PipelineSnapshot set = waitFor (db .pipeline ().createFrom (query ).execute ());
117
+ Pipeline . Snapshot set = waitFor (db .pipeline ().createFrom (query ).execute ());
118
118
List <Map <String , Object >> data = pipelineSnapshotToValues (set );
119
119
assertEquals (
120
120
asList (map ("k" , "a" , "sort" , 0L ), map ("k" , "b" , "sort" , 1L ), map ("k" , "c" , "sort" , 1L )),
@@ -162,7 +162,7 @@ public void testKeyOrderIsDescendingForDescendingInequality() {
162
162
163
163
Query query = collection .whereGreaterThan ("foo" , 21.0 ).orderBy ("foo" , Direction .DESCENDING );
164
164
FirebaseFirestore db = collection .firestore ;
165
- PipelineSnapshot result = waitFor (db .pipeline ().createFrom (query ).execute ());
165
+ Pipeline . Snapshot result = waitFor (db .pipeline ().createFrom (query ).execute ());
166
166
assertEquals (asList ("g" , "f" , "c" , "b" , "a" ), pipelineSnapshotToIds (result ));
167
167
}
168
168
@@ -175,7 +175,7 @@ public void testUnaryFilterQueries() {
175
175
"b" , map ("null" , null , "nan" , 0 ),
176
176
"c" , map ("null" , false , "nan" , Double .NaN )));
177
177
FirebaseFirestore db = collection .firestore ;
178
- PipelineSnapshot results =
178
+ Pipeline . Snapshot results =
179
179
waitFor (
180
180
db .pipeline ()
181
181
.createFrom (collection .whereEqualTo ("null" , null ).whereEqualTo ("nan" , Double .NaN ))
@@ -195,7 +195,7 @@ public void testFilterOnInfinity() {
195
195
"a" , map ("inf" , Double .POSITIVE_INFINITY ),
196
196
"b" , map ("inf" , Double .NEGATIVE_INFINITY )));
197
197
FirebaseFirestore db = collection .firestore ;
198
- PipelineSnapshot results =
198
+ Pipeline . Snapshot results =
199
199
waitFor (
200
200
db .pipeline ()
201
201
.createFrom (collection .whereEqualTo ("inf" , Double .POSITIVE_INFINITY ))
@@ -215,7 +215,7 @@ public void testCanExplicitlySortByDocumentId() {
215
215
FirebaseFirestore db = collection .firestore ;
216
216
// Ideally this would be descending to validate it's different than
217
217
// the default, but that requires an extra index
218
- PipelineSnapshot docs =
218
+ Pipeline . Snapshot docs =
219
219
waitFor (db .pipeline ().createFrom (collection .orderBy (FieldPath .documentId ())).execute ());
220
220
assertEquals (
221
221
asList (testDocs .get ("a" ), testDocs .get ("b" ), testDocs .get ("c" )),
@@ -232,7 +232,7 @@ public void testCanQueryByDocumentId() {
232
232
"bb" , map ("key" , "bb" ));
233
233
CollectionReference collection = testCollectionWithDocs (testDocs );
234
234
FirebaseFirestore db = collection .firestore ;
235
- PipelineSnapshot docs =
235
+ Pipeline . Snapshot docs =
236
236
waitFor (
237
237
db .pipeline ()
238
238
.createFrom (collection .whereEqualTo (FieldPath .documentId (), "ab" ))
@@ -260,7 +260,7 @@ public void testCanQueryByDocumentIdUsingRefs() {
260
260
"bb" , map ("key" , "bb" ));
261
261
CollectionReference collection = testCollectionWithDocs (testDocs );
262
262
FirebaseFirestore db = collection .firestore ;
263
- PipelineSnapshot docs =
263
+ Pipeline . Snapshot docs =
264
264
waitFor (
265
265
db .pipeline ()
266
266
.createFrom (
@@ -284,11 +284,11 @@ public void testCanQueryWithAndWithoutDocumentKey() {
284
284
CollectionReference collection = testCollection ();
285
285
FirebaseFirestore db = collection .firestore ;
286
286
collection .add (map ());
287
- Task <PipelineSnapshot > query1 =
287
+ Task <Pipeline . Snapshot > query1 =
288
288
db .pipeline ()
289
289
.createFrom (collection .orderBy (FieldPath .documentId (), Direction .ASCENDING ))
290
290
.execute ();
291
- Task <PipelineSnapshot > query2 = db .pipeline ().createFrom (collection ).execute ();
291
+ Task <Pipeline . Snapshot > query2 = db .pipeline ().createFrom (collection ).execute ();
292
292
293
293
waitFor (query1 );
294
294
waitFor (query2 );
@@ -325,7 +325,7 @@ public void testQueriesCanUseNotEqualFilters() {
325
325
expectedDocsMap .remove ("i" );
326
326
expectedDocsMap .remove ("j" );
327
327
328
- PipelineSnapshot snapshot =
328
+ Pipeline . Snapshot snapshot =
329
329
waitFor (db .pipeline ().createFrom (collection .whereNotEqualTo ("zip" , 98101L )).execute ());
330
330
assertEquals (Lists .newArrayList (expectedDocsMap .values ()), pipelineSnapshotToValues (snapshot ));
331
331
@@ -372,7 +372,7 @@ public void testQueriesCanUseNotEqualFiltersWithDocIds() {
372
372
"bb" , docD );
373
373
CollectionReference collection = testCollectionWithDocs (testDocs );
374
374
FirebaseFirestore db = collection .firestore ;
375
- PipelineSnapshot docs =
375
+ Pipeline . Snapshot docs =
376
376
waitFor (
377
377
db .pipeline ()
378
378
.createFrom (collection .whereNotEqualTo (FieldPath .documentId (), "aa" ))
@@ -394,7 +394,7 @@ public void testQueriesCanUseArrayContainsFilters() {
394
394
FirebaseFirestore db = collection .firestore ;
395
395
396
396
// Search for "array" to contain 42
397
- PipelineSnapshot snapshot =
397
+ Pipeline . Snapshot snapshot =
398
398
waitFor (db .pipeline ().createFrom (collection .whereArrayContains ("array" , 42L )).execute ());
399
399
assertEquals (asList (docA , docB , docD ), pipelineSnapshotToValues (snapshot ));
400
400
@@ -426,7 +426,7 @@ public void testQueriesCanUseInFilters() {
426
426
FirebaseFirestore db = collection .firestore ;
427
427
428
428
// Search for zips matching 98101, 98103, or [98101, 98102].
429
- PipelineSnapshot snapshot =
429
+ Pipeline . Snapshot snapshot =
430
430
waitFor (
431
431
db .pipeline ()
432
432
.createFrom (
@@ -480,7 +480,7 @@ public void testQueriesCanUseInFiltersWithDocIds() {
480
480
"bb" , docD );
481
481
CollectionReference collection = testCollectionWithDocs (testDocs );
482
482
FirebaseFirestore db = collection .firestore ;
483
- PipelineSnapshot docs =
483
+ Pipeline . Snapshot docs =
484
484
waitFor (
485
485
db .pipeline ()
486
486
.createFrom (collection .whereIn (FieldPath .documentId (), asList ("aa" , "ab" )))
@@ -518,7 +518,7 @@ public void testQueriesCanUseNotInFilters() {
518
518
expectedDocsMap .remove ("i" );
519
519
expectedDocsMap .remove ("j" );
520
520
521
- PipelineSnapshot snapshot =
521
+ Pipeline . Snapshot snapshot =
522
522
waitFor (
523
523
db .pipeline ()
524
524
.createFrom (
@@ -581,7 +581,7 @@ public void testQueriesCanUseNotInFiltersWithDocIds() {
581
581
"bb" , docD );
582
582
CollectionReference collection = testCollectionWithDocs (testDocs );
583
583
FirebaseFirestore db = collection .firestore ;
584
- PipelineSnapshot docs =
584
+ Pipeline . Snapshot docs =
585
585
waitFor (
586
586
db .pipeline ()
587
587
.createFrom (collection .whereNotIn (FieldPath .documentId (), asList ("aa" , "ab" )))
@@ -611,7 +611,7 @@ public void testQueriesCanUseArrayContainsAnyFilters() {
611
611
// Search for "array" to contain [42, 43].
612
612
Pipeline pipeline =
613
613
db .pipeline ().createFrom (collection .whereArrayContainsAny ("array" , asList (42L , 43L )));
614
- PipelineSnapshot snapshot = waitFor (pipeline .execute ());
614
+ Pipeline . Snapshot snapshot = waitFor (pipeline .execute ());
615
615
assertEquals (asList (docA , docB , docD , docE ), pipelineSnapshotToValues (snapshot ));
616
616
617
617
// With objects.
@@ -673,7 +673,7 @@ public void testCollectionGroupQueries() {
673
673
}
674
674
waitFor (batch .commit ());
675
675
676
- PipelineSnapshot snapshot =
676
+ Pipeline . Snapshot snapshot =
677
677
waitFor (db .pipeline ().createFrom (db .collectionGroup (collectionGroup )).execute ());
678
678
assertEquals (
679
679
asList ("cg-doc1" , "cg-doc2" , "cg-doc3" , "cg-doc4" , "cg-doc5" ),
@@ -703,7 +703,7 @@ public void testCollectionGroupQueriesWithStartAtEndAtWithArbitraryDocumentIds()
703
703
}
704
704
waitFor (batch .commit ());
705
705
706
- PipelineSnapshot snapshot =
706
+ Pipeline . Snapshot snapshot =
707
707
waitFor (
708
708
db .pipeline ()
709
709
.createFrom (
@@ -749,7 +749,7 @@ public void testCollectionGroupQueriesWithWhereFiltersOnArbitraryDocumentIds() {
749
749
}
750
750
waitFor (batch .commit ());
751
751
752
- PipelineSnapshot snapshot =
752
+ Pipeline . Snapshot snapshot =
753
753
waitFor (
754
754
db .pipeline ()
755
755
.createFrom (
0 commit comments