diff --git a/tests/Operation/WatchFunctionalTest.php b/tests/Operation/WatchFunctionalTest.php index a7e0ae534..a99b1e7c2 100644 --- a/tests/Operation/WatchFunctionalTest.php +++ b/tests/Operation/WatchFunctionalTest.php @@ -307,15 +307,15 @@ function (array $event) use (&$events): void { $this->assertCount(3, $events); $this->assertSame('getMore', $events[0]['started']->getCommandName()); - $this->arrayHasKey('failed', $events[0]); + $this->assertArrayHasKey('failed', $events[0]); $this->assertSame('aggregate', $events[1]['started']->getCommandName()); $this->assertResumeAfter($postBatchResumeToken, $events[1]['started']->getCommand()); - $this->arrayHasKey('succeeded', $events[1]); + $this->assertArrayHasKey('succeeded', $events[1]); // Original cursor is freed immediately after the change stream resumes $this->assertSame('killCursors', $events[2]['started']->getCommandName()); - $this->arrayHasKey('succeeded', $events[2]); + $this->assertArrayHasKey('succeeded', $events[2]); $this->assertFalse($changeStream->valid()); } @@ -380,15 +380,15 @@ function (array $event) use (&$events): void { $this->assertCount(3, $events); $this->assertSame('getMore', $events[0]['started']->getCommandName()); - $this->arrayHasKey('failed', $events[0]); + $this->assertArrayHasKey('failed', $events[0]); $this->assertSame('aggregate', $events[1]['started']->getCommandName()); $this->assertStartAtOperationTime($operationTime, $events[1]['started']->getCommand()); - $this->arrayHasKey('succeeded', $events[1]); + $this->assertArrayHasKey('succeeded', $events[1]); // Original cursor is freed immediately after the change stream resumes $this->assertSame('killCursors', $events[2]['started']->getCommandName()); - $this->arrayHasKey('succeeded', $events[2]); + $this->assertArrayHasKey('succeeded', $events[2]); $this->assertFalse($changeStream->valid()); }