|
25 | 25 | use MongoDB\Operation\InsertOne; |
26 | 26 | use MongoDB\Operation\Watch; |
27 | 27 | use MongoDB\Tests\CommandObserver; |
| 28 | +use PHPUnit\Framework\Constraint\ObjectHasProperty; |
28 | 29 | use PHPUnit\Framework\ExpectationFailedException; |
29 | 30 | use ReflectionClass; |
30 | 31 | use stdClass; |
@@ -724,10 +725,7 @@ public function testInitialCursorIsNotClosed(): void |
724 | 725 | $this->assertNotEquals(0, $changeStream->getCursorId()); |
725 | 726 |
|
726 | 727 | $rc = new ReflectionClass(ChangeStream::class); |
727 | | - $rp = $rc->getProperty('iterator'); |
728 | | - $rp->setAccessible(true); |
729 | | - |
730 | | - $iterator = $rp->getValue($changeStream); |
| 728 | + $iterator = $rc->getProperty('iterator')->getValue($changeStream); |
731 | 729 |
|
732 | 730 | $this->assertInstanceOf('IteratorIterator', $iterator); |
733 | 731 |
|
@@ -1225,7 +1223,6 @@ public function testSessionFreed(): void |
1225 | 1223 |
|
1226 | 1224 | $rc = new ReflectionClass($changeStream); |
1227 | 1225 | $rp = $rc->getProperty('resumeCallable'); |
1228 | | - $rp->setAccessible(true); |
1229 | 1226 |
|
1230 | 1227 | $this->assertIsCallable($rp->getValue($changeStream)); |
1231 | 1228 |
|
@@ -1282,19 +1279,19 @@ function (array $event) use (&$aggregateCommands): void { |
1282 | 1279 | $aggregateCommands[0]['pipeline'][0]->{'$changeStream'}, |
1283 | 1280 | $this->logicalNot( |
1284 | 1281 | $this->logicalOr( |
1285 | | - $this->objectHasAttribute('resumeAfter'), |
1286 | | - $this->objectHasAttribute('startAfter'), |
1287 | | - $this->objectHasAttribute('startAtOperationTime'), |
| 1282 | + new ObjectHasProperty('resumeAfter'), |
| 1283 | + new ObjectHasProperty('startAfter'), |
| 1284 | + new ObjectHasProperty('startAtOperationTime'), |
1288 | 1285 | ), |
1289 | 1286 | ), |
1290 | 1287 | ); |
1291 | 1288 |
|
1292 | 1289 | $this->assertThat( |
1293 | 1290 | $aggregateCommands[1]['pipeline'][0]->{'$changeStream'}, |
1294 | 1291 | $this->logicalOr( |
1295 | | - $this->objectHasAttribute('resumeAfter'), |
1296 | | - $this->objectHasAttribute('startAfter'), |
1297 | | - $this->objectHasAttribute('startAtOperationTime'), |
| 1292 | + new ObjectHasProperty('resumeAfter'), |
| 1293 | + new ObjectHasProperty('startAfter'), |
| 1294 | + new ObjectHasProperty('startAtOperationTime'), |
1298 | 1295 | ), |
1299 | 1296 | ); |
1300 | 1297 |
|
|
0 commit comments