Unverified Commit c69a7155 authored by Andreas Braun's avatar Andreas Braun

Merge pull request #676

parents e0a2b899 6bf06710
...@@ -980,6 +980,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -980,6 +980,7 @@ class WatchFunctionalTest extends FunctionalTestCase
$options = $this->defaultOptions + ['resumeAfter' => $resumeToken]; $options = $this->defaultOptions + ['resumeAfter' => $resumeToken];
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], $options); $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], $options);
$changeStream = $operation->execute($this->getPrimaryServer()); $changeStream = $operation->execute($this->getPrimaryServer());
$this->assertSame($resumeToken, $changeStream->getResumeToken());
$changeStream->rewind(); $changeStream->rewind();
$this->assertTrue($changeStream->valid()); $this->assertTrue($changeStream->valid());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment