File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -100,7 +100,7 @@ public function next()
100
100
$ resumable = true ;
101
101
}
102
102
if ($ e ->getCode () === self ::CURSOR_NOT_FOUND ) {
103
- $ resumable = true ;
103
+ $ resumable = true ;
104
104
}
105
105
if ($ e instanceof ConnectionTimeoutException) {
106
106
$ resumable = true ;
@@ -147,7 +147,7 @@ private function extractResumeToken($document)
147
147
if (isset ($ document ->_id )) {
148
148
$ this ->resumeToken = is_array ($ document ) ? $ document ['_id ' ] : $ document ->_id ;
149
149
} else {
150
- throw new ResumeTokenException ("Cannot provide resume functionality when the resume token is missing " );
150
+ throw new ResumeTokenException ("Cannot provide resume functionality when the resume token is missing " );
151
151
}
152
152
}
153
153
Original file line number Diff line number Diff line change @@ -21,7 +21,7 @@ public function setUp()
21
21
if (version_compare ($ this ->getFeatureCompatibilityVersion (), '3.6 ' , '< ' )) {
22
22
$ this ->markTestSkipped ('$changeStream is only supported on FCV 3.6 or higher ' );
23
23
}
24
- }
24
+ }
25
25
26
26
public function testResume ()
27
27
{
@@ -59,7 +59,7 @@ public function testResume()
59
59
'documentKey ' => (object ) ['_id ' => 3 ]
60
60
]);
61
61
$ this ->assertEquals ($ expectedResult , $ changeStream ->current ());
62
- }
62
+ }
63
63
64
64
public function testNoChangeAfterResumeBeforeInsert ()
65
65
{
You can’t perform that action at this time.
0 commit comments