Assert change stream validity after calling next()

Author: jmikola

tests/Operation/WatchFunctionalTest.php

@@ -42,6 +42,7 @@ public function testResume()
         $this->insertDocument(['_id' => 2, 'x' => 'bar']);
 
         $changeStream->next();
+        $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
             '_id' => $changeStream->current()->_id,
@@ -58,6 +59,7 @@ public function testResume()
         $this->insertDocument(['_id' => 3, 'x' => 'baz']);
 
         $changeStream->next();
+        $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
             '_id' => $changeStream->current()->_id,
@@ -139,6 +141,7 @@ public function testNoChangeAfterResumeBeforeInsert()
         $this->insertDocument(['_id' => 2, 'x' => 'bar']);
 
         $changeStream->next();
+        $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
             '_id' => $changeStream->current()->_id,
@@ -153,11 +156,13 @@ public function testNoChangeAfterResumeBeforeInsert()
         $this->killChangeStreamCursor($changeStream);
 
         $changeStream->next();
+        $this->assertFalse($changeStream->valid());
         $this->assertNull($changeStream->current());
 
         $this->insertDocument(['_id' => 3, 'x' => 'baz']);
 
         $changeStream->next();
+        $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
             '_id' => $changeStream->current()->_id,
@@ -178,6 +183,7 @@ public function testResumeAfterKillThenNoOperations()
         $this->killChangeStreamCursor($changeStream);
 
         $changeStream->next();
+        $this->assertFalse($changeStream->valid());
         $this->assertNull($changeStream->current());
     }
 
@@ -191,6 +197,7 @@ public function testResumeAfterKillThenOperation()
         $this->insertDocument(['_id' => 1, 'x' => 'foo']);
 
         $changeStream->next();
+        $this->assertFalse($changeStream->valid());
         $this->assertNull($changeStream->current());
     }
 
@@ -204,21 +211,27 @@ public function testKey()
         $this->insertDocument(['_id' => 1, 'x' => 'foo']);
 
         $changeStream->next();
+        $this->assertTrue($changeStream->valid());
         $this->assertSame(1, $changeStream->key());
 
         $changeStream->next();
+        $this->assertFalse($changeStream->valid());
         $this->assertNull($changeStream->key());
+
         $changeStream->next();
+        $this->assertFalse($changeStream->valid());
         $this->assertNull($changeStream->key());
 
         $this->killChangeStreamCursor($changeStream);
 
         $changeStream->next();
+        $this->assertFalse($changeStream->valid());
         $this->assertNull($changeStream->key());
 
         $this->insertDocument(['_id' => 2, 'x' => 'bar']);
 
         $changeStream->next();
+        $this->assertTrue($changeStream->valid());
         $this->assertSame(2, $changeStream->key());
     }
 
@@ -232,6 +245,7 @@ public function testNonEmptyPipeline()
         $this->insertDocument(['_id' => 1]);
 
         $changeStream->next();
+        $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
             '_id' => $changeStream->current()->_id,