diff --git a/src/Collection.php b/src/Collection.php index 93839d68c..c2931d46f 100644 --- a/src/Collection.php +++ b/src/Collection.php @@ -967,6 +967,10 @@ public function watch(array $pipeline = [], array $options = []) $options['readConcern'] = $this->readConcern; } + if ( ! isset($options['typeMap'])) { + $options['typeMap'] = $this->typeMap; + } + $operation = new Watch($this->manager, $this->databaseName, $this->collectionName, $pipeline, $options); return $operation->execute($server);