diff --git a/tests/Operation/WatchFunctionalTest.php b/tests/Operation/WatchFunctionalTest.php index 251ca0f6f..43711251c 100644 --- a/tests/Operation/WatchFunctionalTest.php +++ b/tests/Operation/WatchFunctionalTest.php @@ -980,6 +980,7 @@ public function testResumeAfterOption() $options = $this->defaultOptions + ['resumeAfter' => $resumeToken]; $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], $options); $changeStream = $operation->execute($this->getPrimaryServer()); + $this->assertSame($resumeToken, $changeStream->getResumeToken()); $changeStream->rewind(); $this->assertTrue($changeStream->valid());