Commit 8acab3b4 authored by Jeremy Mikola's avatar Jeremy Mikola

Fix indentation

parent 6a46e15c
...@@ -100,7 +100,7 @@ class ChangeStream implements Iterator ...@@ -100,7 +100,7 @@ class ChangeStream implements Iterator
$resumable = true; $resumable = true;
} }
if ($e->getCode() === self::CURSOR_NOT_FOUND) { if ($e->getCode() === self::CURSOR_NOT_FOUND) {
$resumable = true; $resumable = true;
} }
if ($e instanceof ConnectionTimeoutException) { if ($e instanceof ConnectionTimeoutException) {
$resumable = true; $resumable = true;
...@@ -147,7 +147,7 @@ class ChangeStream implements Iterator ...@@ -147,7 +147,7 @@ class ChangeStream implements Iterator
if (isset($document->_id)) { if (isset($document->_id)) {
$this->resumeToken = is_array($document) ? $document['_id'] : $document->_id; $this->resumeToken = is_array($document) ? $document['_id'] : $document->_id;
} else { } else {
throw new ResumeTokenException("Cannot provide resume functionality when the resume token is missing"); throw new ResumeTokenException("Cannot provide resume functionality when the resume token is missing");
} }
} }
......
...@@ -21,7 +21,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -21,7 +21,7 @@ class WatchFunctionalTest extends FunctionalTestCase
if (version_compare($this->getFeatureCompatibilityVersion(), '3.6', '<')) { if (version_compare($this->getFeatureCompatibilityVersion(), '3.6', '<')) {
$this->markTestSkipped('$changeStream is only supported on FCV 3.6 or higher'); $this->markTestSkipped('$changeStream is only supported on FCV 3.6 or higher');
} }
} }
public function testResume() public function testResume()
{ {
...@@ -59,7 +59,7 @@ class WatchFunctionalTest extends FunctionalTestCase ...@@ -59,7 +59,7 @@ class WatchFunctionalTest extends FunctionalTestCase
'documentKey' => (object) ['_id' => 3] 'documentKey' => (object) ['_id' => 3]
]); ]);
$this->assertEquals($expectedResult, $changeStream->current()); $this->assertEquals($expectedResult, $changeStream->current());
} }
public function testNoChangeAfterResumeBeforeInsert() public function testNoChangeAfterResumeBeforeInsert()
{ {
......
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