diff --git a/tests/Operation/WatchFunctionalTest.php b/tests/Operation/WatchFunctionalTest.php
index 3bbbca2ccc952c8c8a0ddb9e0671bba35fba2c2a..e0edbe65c0d12d50243e41c0a223fe38781c6ae9 100644
--- a/tests/Operation/WatchFunctionalTest.php
+++ b/tests/Operation/WatchFunctionalTest.php
@@ -220,7 +220,7 @@ class WatchFunctionalTest extends FunctionalTestCase
 
         $this->insertDocument(['_id' => 1]);
 
-        $changeStream->next();
+        $changeStream->rewind();
         $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
@@ -260,14 +260,17 @@ class WatchFunctionalTest extends FunctionalTestCase
 
     /**
      * @expectedException MongoDB\Exception\ResumeTokenException
+     * @todo test that rewind() also attempts to extract the resume token once PHPLIB-322 is implemented
      */
-    public function testFailureAfterResumeTokenRemoved()
+    public function testNextCannotExtractResumeToken()
     {
         $pipeline =  [['$project' => ['_id' => 0 ]]];
 
         $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), $pipeline, ['maxAwaitTimeMS' => 100]);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
+        $changeStream->rewind();
+
         $this->insertDocument(['x' => 1]);
 
         $changeStream->next();