@@ -29,7 +29,7 @@ public function setUp()
29
29
}
30
30
}
31
31
32
- public function testResume ()
32
+ public function testNextResumesAfterCursorNotFound ()
33
33
{
34
34
$ this ->insertDocument (['_id ' => 1 , 'x ' => 'foo ' ]);
35
35
@@ -175,32 +175,6 @@ public function testNoChangeAfterResumeBeforeInsert()
175
175
$ this ->assertSameDocument ($ expectedResult , $ changeStream ->current ());
176
176
}
177
177
178
- public function testResumeAfterKillThenNoOperations ()
179
- {
180
- $ operation = new Watch ($ this ->manager , $ this ->getDatabaseName (), $ this ->getCollectionName (), [], ['maxAwaitTimeMS ' => 100 ]);
181
- $ changeStream = $ operation ->execute ($ this ->getPrimaryServer ());
182
-
183
- $ this ->killChangeStreamCursor ($ changeStream );
184
-
185
- $ changeStream ->next ();
186
- $ this ->assertFalse ($ changeStream ->valid ());
187
- $ this ->assertNull ($ changeStream ->current ());
188
- }
189
-
190
- public function testResumeAfterKillThenOperation ()
191
- {
192
- $ operation = new Watch ($ this ->manager , $ this ->getDatabaseName (), $ this ->getCollectionName (), [], ['maxAwaitTimeMS ' => 100 ]);
193
- $ changeStream = $ operation ->execute ($ this ->getPrimaryServer ());
194
-
195
- $ this ->killChangeStreamCursor ($ changeStream );
196
-
197
- $ this ->insertDocument (['_id ' => 1 , 'x ' => 'foo ' ]);
198
-
199
- $ changeStream ->next ();
200
- $ this ->assertFalse ($ changeStream ->valid ());
201
- $ this ->assertNull ($ changeStream ->current ());
202
- }
203
-
204
178
public function testKey ()
205
179
{
206
180
$ operation = new Watch ($ this ->manager , $ this ->getDatabaseName (), $ this ->getCollectionName (), [], ['maxAwaitTimeMS ' => 100 ]);
0 commit comments