@@ -29,7 +29,7 @@ public function setUp()
2929 }
3030 }
3131
32- public function testResume ()
32+ public function testNextResumesAfterCursorNotFound ()
3333 {
3434 $ this ->insertDocument (['_id ' => 1 , 'x ' => 'foo ' ]);
3535
@@ -175,32 +175,6 @@ public function testNoChangeAfterResumeBeforeInsert()
175175 $ this ->assertSameDocument ($ expectedResult , $ changeStream ->current ());
176176 }
177177
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-
204178 public function testKey ()
205179 {
206180 $ operation = new Watch ($ this ->manager , $ this ->getDatabaseName (), $ this ->getCollectionName (), [], ['maxAwaitTimeMS ' => 100 ]);
0 commit comments