Use smaller maxAwaitTimeMS to speed up change stream tests

Author: jmikola

tests/Operation/WatchFunctionalTest.php

@@ -33,7 +33,7 @@ public function testResume()
     {
         $this->insertDocument(['_id' => 1, 'x' => 'foo']);
 
-        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []);
+        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $changeStream->rewind();
@@ -130,7 +130,7 @@ public function testNoChangeAfterResumeBeforeInsert()
     {
         $this->insertDocument(['_id' => 1, 'x' => 'foo']);
 
-        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []);
+        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $changeStream->rewind();
@@ -172,7 +172,7 @@ public function testNoChangeAfterResumeBeforeInsert()
 
     public function testResumeAfterKillThenNoOperations()
     {
-        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []);
+        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $this->killChangeStreamCursor($changeStream);
@@ -183,7 +183,7 @@ public function testResumeAfterKillThenNoOperations()
 
     public function testResumeAfterKillThenOperation()
     {
-        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []);
+        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $this->killChangeStreamCursor($changeStream);
@@ -196,7 +196,7 @@ public function testResumeAfterKillThenOperation()
 
     public function testKey()
     {
-        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []);
+        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $this->assertNull($changeStream->key());
@@ -226,7 +226,7 @@ public function testNonEmptyPipeline()
     {
         $pipeline = [['$project' => ['foo' => [0]]]];
 
-        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), $pipeline);
+        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), $pipeline, ['maxAwaitTimeMS' => 100]);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $this->insertDocument(['_id' => 1]);
@@ -243,7 +243,7 @@ public function testNonEmptyPipeline()
 
     public function testCursorWithEmptyBatchNotClosed()
     {
-        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), []);
+        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], ['maxAwaitTimeMS' => 100]);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $this->assertNotNull($changeStream);
@@ -256,7 +256,7 @@ public function testFailureAfterResumeTokenRemoved()
     {
         $pipeline =  [['$project' => ['_id' => 0 ]]];
 
-        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), $pipeline);
+        $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), $pipeline, ['maxAwaitTimeMS' => 100]);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $this->insertDocument(['x' => 1]);