Unverified Commit 6bf06710 authored by Jeremy Mikola's avatar Jeremy Mikola Committed by GitHub

Assert initial resume token in resumeAfter test

ChangeStream::getResumeToken() did not exist at the time this test was written; however, we do this assertion in testStartAfterOption().
parent e0a2b899
...@@ -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