@@ -128,31 +128,30 @@ public function getFileCollection($refresh = false)
128
128
'name ' => $ this ->name
129
129
]);
130
130
}
131
-
132
131
return $ this ->_fileCollection ;
133
132
}
134
133
135
134
/**
136
135
* {@inheritdoc}
137
136
*/
138
- public function drop ()
137
+ public function drop ($ execOptions = [] )
139
138
{
140
- return parent ::drop () && $ this ->database ->dropCollection ($ this ->getChunkCollection ()->name );
139
+ return parent ::drop ($ execOptions ) && $ this ->database ->dropCollection ($ this ->getChunkCollection ()->name , $ execOptions );
141
140
}
142
141
143
142
/**
144
143
* {@inheritdoc}
145
144
* @return Cursor cursor for the search results
146
145
*/
147
- public function find ($ condition = [], $ fields = [], $ options = [])
146
+ public function find ($ condition = [], $ fields = [], $ options = [], $ execOptions = [] )
148
147
{
149
- return new Cursor ($ this , parent ::find ($ condition , $ fields , $ options ));
148
+ return new Cursor ($ this , parent ::find ($ condition , $ fields , $ options, $ execOptions ));
150
149
}
151
150
152
151
/**
153
152
* {@inheritdoc}
154
153
*/
155
- public function remove ($ condition = [], $ options = [])
154
+ public function remove ($ condition = [], $ options = [], $ execOptions = [] )
156
155
{
157
156
$ fileCollection = $ this ->getFileCollection ();
158
157
$ chunkCollection = $ this ->getChunkCollection ();
@@ -166,7 +165,7 @@ public function remove($condition = [], $options = [])
166
165
167
166
$ batchSize = 200 ;
168
167
$ options ['batchSize ' ] = $ batchSize ;
169
- $ cursor = $ fileCollection ->find ($ condition , ['_id ' ], $ options );
168
+ $ cursor = $ fileCollection ->find ($ condition , ['_id ' ], $ options, $ execOptions );
170
169
unset($ options ['limit ' ]);
171
170
$ deleteCount = 0 ;
172
171
$ deleteCallback = function ($ ids ) use ($ fileCollection , $ chunkCollection , $ options ) {
0 commit comments