File tree Expand file tree Collapse file tree
test/acceptance/org/mongodb/acceptancetest/core Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -540,6 +540,13 @@ public MongoCollectionPipeline(final MongoCollectionPipeline from) {
540540 pipeline = new ArrayList <Document >(from .pipeline );
541541 }
542542
543+ @ Override
544+ public MongoPipeline <T > find (final Document criteria ) {
545+ MongoCollectionPipeline newPipeline = new MongoCollectionPipeline (this );
546+ newPipeline .pipeline .add (new Document ("$match" , criteria ));
547+ return newPipeline ;
548+ }
549+
543550 @ Override
544551 public MongoPipeline <T > sort (final Document sortCriteria ) {
545552 MongoCollectionPipeline newPipeline = new MongoCollectionPipeline (this );
@@ -561,13 +568,6 @@ public MongoPipeline<T> limit(final long limit) {
561568 return newPipeline ;
562569 }
563570
564- @ Override
565- public MongoPipeline <T > match (final Document match ) {
566- MongoCollectionPipeline newPipeline = new MongoCollectionPipeline (this );
567- newPipeline .pipeline .add (new Document ("$match" , match ));
568- return newPipeline ;
569- }
570-
571571 @ Override
572572 public MongoPipeline <T > project (final Document projection ) {
573573 MongoCollectionPipeline newPipeline = new MongoCollectionPipeline (this );
Original file line number Diff line number Diff line change 1717package org .mongodb ;
1818
1919public interface MongoPipeline <T > extends MongoIterable <T > {
20+ MongoPipeline <T > find (Document criteria );
21+
2022 MongoPipeline <T > sort (Document id );
2123
2224 MongoPipeline <T > skip (long skip );
2325
2426 MongoPipeline <T > limit (long limit );
2527
26- MongoPipeline <T > match (Document match );
27-
2828 MongoPipeline <T > project (Document projection );
2929
3030 MongoPipeline <T > group (Document group );
Original file line number Diff line number Diff line change @@ -112,8 +112,8 @@ public void shouldLimitDocuments() {
112112 }
113113
114114 @ Test
115- public void shouldMatchDocuments () {
116- List <Document > matched = collection .pipe ().match (new Document ("_id" , "10012" )).into (new ArrayList <Document >());
115+ public void shouldFindDocuments () {
116+ List <Document > matched = collection .pipe ().find (new Document ("_id" , "10012" )).into (new ArrayList <Document >());
117117 assertEquals (documents .subList (1 , 2 ), matched );
118118 }
119119
You can’t perform that action at this time.
0 commit comments