@@ -43,7 +43,7 @@ public function testResume()
43
43
'ns ' => (object ) ['db ' => 'phplib_test ' , 'coll ' => 'WatchFunctionalTest.e68b9f01 ' ],
44
44
'documentKey ' => (object ) ['_id ' => 2 ]
45
45
]);
46
- $ this ->assertEquals ($ changeStream ->current (), $ expectedResult );
46
+ $ this ->assertEquals ($ expectedResult , $ changeStream ->current ());
47
47
48
48
$ operation = new DatabaseCommand ($ this ->getDatabaseName (), ["killCursors " => $ this ->getCollectionName (), "cursors " => [$ changeStream ->getCursorId ()]]);
49
49
$ operation ->execute ($ this ->getPrimaryServer ());
@@ -58,7 +58,7 @@ public function testResume()
58
58
'ns ' => (object ) ['db ' => 'phplib_test ' , 'coll ' => 'WatchFunctionalTest.e68b9f01 ' ],
59
59
'documentKey ' => (object ) ['_id ' => 3 ]
60
60
]);
61
- $ this ->assertEquals ($ changeStream ->current (), $ expectedResult );
61
+ $ this ->assertEquals ($ expectedResult , $ changeStream ->current ());
62
62
}
63
63
64
64
public function testNoChangeAfterResumeBeforeInsert ()
@@ -81,7 +81,7 @@ public function testNoChangeAfterResumeBeforeInsert()
81
81
'ns ' => (object ) ['db ' => 'phplib_test ' , 'coll ' => 'WatchFunctionalTest.4a554985 ' ],
82
82
'documentKey ' => (object ) ['_id ' => 2 ]
83
83
]);
84
- $ this ->assertEquals ($ changeStream ->current (), $ expectedResult );
84
+ $ this ->assertEquals ($ expectedResult , $ changeStream ->current ());
85
85
86
86
$ operation = new DatabaseCommand ($ this ->getDatabaseName (), ["killCursors " => $ this ->getCollectionName (), "cursors " => [$ changeStream ->getCursorId ()]]);
87
87
$ operation ->execute ($ this ->getPrimaryServer ());
@@ -99,7 +99,7 @@ public function testNoChangeAfterResumeBeforeInsert()
99
99
'ns ' => (object ) ['db ' => 'phplib_test ' , 'coll ' => 'WatchFunctionalTest.4a554985 ' ],
100
100
'documentKey ' => (object ) ['_id ' => 3 ]
101
101
]);
102
- $ this ->assertEquals ($ changeStream ->current (), $ expectedResult );
102
+ $ this ->assertEquals ($ expectedResult , $ changeStream ->current ());
103
103
}
104
104
105
105
public function testResumeAfterKillThenNoOperations ()
@@ -171,7 +171,7 @@ public function testNonEmptyPipeline()
171
171
'_id ' => $ changeStream ->current ()->_id ,
172
172
'foo ' => [0 ]
173
173
]);
174
- $ this ->assertEquals ($ changeStream ->current (), $ expectedResult );
174
+ $ this ->assertEquals ($ expectedResult , $ changeStream ->current ());
175
175
}
176
176
177
177
public function testCursorWithEmptyBatchNotClosed ()
0 commit comments