@@ -28,8 +28,8 @@ function() {
28
28
29
29
$ operation ->execute ($ this ->getPrimaryServer ());
30
30
},
31
- function (stdClass $ command ) {
32
- $ this ->assertSame (1 , $ command ->aggregate );
31
+ function (array $ event ) {
32
+ $ this ->assertSame (1 , $ event [ ' started ' ]-> getCommand () ->aggregate );
33
33
}
34
34
);
35
35
}
@@ -47,8 +47,8 @@ function() {
47
47
48
48
$ operation ->execute ($ this ->getPrimaryServer ());
49
49
},
50
- function (stdClass $ command ) {
51
- $ this ->assertObjectNotHasAttribute ('readConcern ' , $ command );
50
+ function (array $ event ) {
51
+ $ this ->assertObjectNotHasAttribute ('readConcern ' , $ event [ ' started ' ]-> getCommand () );
52
52
}
53
53
);
54
54
}
@@ -66,8 +66,8 @@ function() {
66
66
67
67
$ operation ->execute ($ this ->getPrimaryServer ());
68
68
},
69
- function (stdClass $ command ) {
70
- $ this ->assertObjectNotHasAttribute ('writeConcern ' , $ command );
69
+ function (array $ event ) {
70
+ $ this ->assertObjectNotHasAttribute ('writeConcern ' , $ event [ ' started ' ]-> getCommand () );
71
71
}
72
72
);
73
73
}
@@ -112,8 +112,8 @@ function() {
112
112
113
113
$ operation ->execute ($ this ->getPrimaryServer ());
114
114
},
115
- function (stdClass $ command ) {
116
- $ this ->assertObjectHasAttribute ('lsid ' , $ command );
115
+ function (array $ event ) {
116
+ $ this ->assertObjectHasAttribute ('lsid ' , $ event [ ' started ' ]-> getCommand () );
117
117
}
118
118
);
119
119
}
@@ -185,8 +185,8 @@ function() use ($pipeline, $options) {
185
185
$ this ->assertCount (1 , $ results );
186
186
$ this ->assertObjectHasAttribute ('stages ' , current ($ results ));
187
187
},
188
- function (stdClass $ command ) {
189
- $ this ->assertObjectNotHasAttribute ('writeConcern ' , $ command );
188
+ function (array $ event ) {
189
+ $ this ->assertObjectNotHasAttribute ('writeConcern ' , $ event [ ' started ' ]-> getCommand () );
190
190
}
191
191
);
192
192
0 commit comments