private function createAggregate()
    {
        $pipeline = $this->pipeline;
        array_unshift($pipeline, ['$changeStream' => (object) $this->changeStreamOptions]);

        return new Aggregate($this->databaseName, $this->collectionName, $pipeline, $this->aggregateOptions);
    }
private function createAggregate()
    {
        $pipeline = $this->pipeline;
        array_unshift($pipeline, ['$changeStream' => (object) $this->changeStreamOptions]);

        return new Aggregate($this->databaseName, $this->collectionName, $pipeline, $this->aggregateOptions);
    }
private function createAggregate ( ) { $ pipeline = $ this -> pipeline ; array_unshift ( $ pipeline , [ '$changeStream' => ( object ) $ this -> changeStreamOptions ] ) ; return new Aggregate ( $ this -> databaseName , $ this -> collectionName , $ pipeline , $ this -> aggregateOptions ) ; }
Create the aggregate command for creating a change stream.

This method is also used to recreate the aggregate command when resuming.

@return Aggregate
Create the aggregate command for creating a change stream .