original_string: private function createAggregate()
      {
          $pipeline = $this->pipeline;
          array_unshift($pipeline, ['$changeStream' => (object) $this->changeStreamOptions]);
  
          return new Aggregate($this->databaseName, $this->collectionName, $pipeline, $this->aggregateOptions);
      }
code: private function createAggregate()
      {
          $pipeline = $this->pipeline;
          array_unshift($pipeline, ['$changeStream' => (object) $this->changeStreamOptions]);
  
          return new Aggregate($this->databaseName, $this->collectionName, $pipeline, $this->aggregateOptions);
      }
code_tokens: private function createAggregate ( ) { $ pipeline = $ this -> pipeline ; array_unshift ( $ pipeline , [ '$changeStream' => ( object ) $ this -> changeStreamOptions ] ) ; return new Aggregate ( $ this -> databaseName , $ this -> collectionName , $ pipeline , $ this -> aggregateOptions ) ; }
docstring: Create the aggregate command for creating a change stream.
  
  This method is also used to recreate the aggregate command when resuming.
  
  @return Aggregate
docstring_tokens: Create the aggregate command for creating a change stream .