@@ -307,15 +307,15 @@ function (array $event) use (&$events): void {
307
307
$ this ->assertCount (3 , $ events );
308
308
309
309
$ this ->assertSame ('getMore ' , $ events [0 ]['started ' ]->getCommandName ());
310
- $ this ->arrayHasKey ('failed ' , $ events [0 ]);
310
+ $ this ->assertArrayHasKey ('failed ' , $ events [0 ]);
311
311
312
312
$ this ->assertSame ('aggregate ' , $ events [1 ]['started ' ]->getCommandName ());
313
313
$ this ->assertResumeAfter ($ postBatchResumeToken , $ events [1 ]['started ' ]->getCommand ());
314
- $ this ->arrayHasKey ('succeeded ' , $ events [1 ]);
314
+ $ this ->assertArrayHasKey ('succeeded ' , $ events [1 ]);
315
315
316
316
// Original cursor is freed immediately after the change stream resumes
317
317
$ this ->assertSame ('killCursors ' , $ events [2 ]['started ' ]->getCommandName ());
318
- $ this ->arrayHasKey ('succeeded ' , $ events [2 ]);
318
+ $ this ->assertArrayHasKey ('succeeded ' , $ events [2 ]);
319
319
320
320
$ this ->assertFalse ($ changeStream ->valid ());
321
321
}
@@ -380,15 +380,15 @@ function (array $event) use (&$events): void {
380
380
$ this ->assertCount (3 , $ events );
381
381
382
382
$ this ->assertSame ('getMore ' , $ events [0 ]['started ' ]->getCommandName ());
383
- $ this ->arrayHasKey ('failed ' , $ events [0 ]);
383
+ $ this ->assertArrayHasKey ('failed ' , $ events [0 ]);
384
384
385
385
$ this ->assertSame ('aggregate ' , $ events [1 ]['started ' ]->getCommandName ());
386
386
$ this ->assertStartAtOperationTime ($ operationTime , $ events [1 ]['started ' ]->getCommand ());
387
- $ this ->arrayHasKey ('succeeded ' , $ events [1 ]);
387
+ $ this ->assertArrayHasKey ('succeeded ' , $ events [1 ]);
388
388
389
389
// Original cursor is freed immediately after the change stream resumes
390
390
$ this ->assertSame ('killCursors ' , $ events [2 ]['started ' ]->getCommandName ());
391
- $ this ->arrayHasKey ('succeeded ' , $ events [2 ]);
391
+ $ this ->assertArrayHasKey ('succeeded ' , $ events [2 ]);
392
392
393
393
$ this ->assertFalse ($ changeStream ->valid ());
394
394
}
0 commit comments