diff --git a/src/file/Collection.php b/src/file/Collection.php index 860867c96..1ede82dad 100644 --- a/src/file/Collection.php +++ b/src/file/Collection.php @@ -128,31 +128,30 @@ public function getFileCollection($refresh = false) 'name' => $this->name ]); } - return $this->_fileCollection; } /** * {@inheritdoc} */ - public function drop() + public function drop($execOptions = []) { - return parent::drop() && $this->database->dropCollection($this->getChunkCollection()->name); + return parent::drop($execOptions) && $this->database->dropCollection($this->getChunkCollection()->name,$execOptions); } /** * {@inheritdoc} * @return Cursor cursor for the search results */ - public function find($condition = [], $fields = [], $options = []) + public function find($condition = [], $fields = [], $options = [], $execOptions = []) { - return new Cursor($this, parent::find($condition, $fields, $options)); + return new Cursor($this, parent::find($condition, $fields, $options, $execOptions)); } /** * {@inheritdoc} */ - public function remove($condition = [], $options = []) + public function remove($condition = [], $options = [], $execOptions = []) { $fileCollection = $this->getFileCollection(); $chunkCollection = $this->getChunkCollection(); @@ -166,7 +165,7 @@ public function remove($condition = [], $options = []) $batchSize = 200; $options['batchSize'] = $batchSize; - $cursor = $fileCollection->find($condition, ['_id'], $options); + $cursor = $fileCollection->find($condition, ['_id'], $options, $execOptions); unset($options['limit']); $deleteCount = 0; $deleteCallback = function ($ids) use ($fileCollection, $chunkCollection, $options) {