remov Pipeline type

Author: rustagir

source/aggregation.txt

@@ -195,9 +195,9 @@ Aggregation Builder
 To create an aggregation pipeline by using the Aggregation Builder,
 perform the following actions:
 
-#. Create a ``Pipeline`` class instance to initialize the pipeline
+#. Create an array to store the pipeline stages
 
-#. Within the ``Pipeline`` instance, call an operator method from the ``Stage``
+#. For each stage, call an operator method from the ``Stage``
    builder class to create that type of aggregation stage
 
 #. Within the body of the ``Stage`` method, use methods from other
@@ -209,23 +209,17 @@ aggregation pipelines:
 
 .. code-block:: php
 
-   $pipeline = new Pipeline(
+   $pipeline = [
        Stage::<operator method>(
            <stage specification>
        ),
        Stage::<operator method>(
            <stage specification>
        ),
        ...
-   );
+   ];
 
-   $cursor = $collection->aggregate(iterator_to_array($pipeline));
-
-.. note::
-    
-   The preceding code uses the ``iterator_to_array()`` method to
-   convert the ``Pipeline`` instance into an array. You must call this method
-   on your ``Pipeline`` before passing it to the ``aggregate()`` method.
+   $cursor = $collection->aggregate($pipeline);
 
 The examples in this section are adapted from the {+mdb-server+} manual.
 Each example provides a link to the sample data that you can insert into

source/includes/aggregation/aggregation.php

@@ -3,7 +3,6 @@
 use MongoDB\BSON\UTCDateTime;
 use MongoDB\Builder\Accumulator;
 use MongoDB\Builder\Expression;
-use MongoDB\Builder\Pipeline;
 use MongoDB\Builder\Query;
 use MongoDB\Builder\Stage;
 use MongoDB\Builder\Type\Sort;
@@ -48,7 +47,7 @@
 // end-array-explain
 
 // start-builder-match-group
-$pipeline = new Pipeline(
+$pipeline = [
     Stage::match(
         date: [
             Query::gte(new UTCDateTime(new DateTimeImmutable('2014-01-01'))),
@@ -71,17 +70,17 @@
     Stage::sort(
         totalSaleAmount: Sort::Desc,
     ),
-);
+];
 
-$cursor = $collection->aggregate(iterator_to_array($pipeline));
+$cursor = $collection->aggregate($pipeline);
 
 foreach ($cursor as $doc) {
     echo json_encode($doc), PHP_EOL;
 }
 // end-builder-match-group
 
 // start-builder-unwind
-$pipeline = new Pipeline(
+$pipeline = [
     Stage::unwind(Expression::arrayFieldPath('items')),
     Stage::unwind(Expression::arrayFieldPath('items.tags')),
     Stage::group(
@@ -93,27 +92,27 @@
             ),
         ),
     ),
-);
+];
 
-$cursor = $collection->aggregate(iterator_to_array($pipeline));
+$cursor = $collection->aggregate($pipeline);
 
 foreach ($cursor as $doc) {
     echo json_encode($doc), PHP_EOL;
 }
 // end-builder-unwind
 
 // start-builder-lookup
-$pipeline = new Pipeline(
+$pipeline = [
     Stage::lookup(
         from: 'inventory',
         localField: 'item',
         foreignField: 'sku',
         as: 'inventory_docs',
     ),
-);
+];
 
 /* Perform the aggregation on the orders collection */
-$cursor = $collection->aggregate(iterator_to_array($pipeline));
+$cursor = $collection->aggregate($pipeline);
 
 foreach ($cursor as $doc) {
     echo json_encode($doc), PHP_EOL;