diff --git a/mongo/database.go b/mongo/database.go
index ebc574cbf4..414971c870 100644
--- a/mongo/database.go
+++ b/mongo/database.go
@@ -574,6 +574,7 @@ func (db *Database) Watch(ctx context.Context, pipeline interface{},
 		readConcern:    db.readConcern,
 		readPreference: db.readPreference,
 		client:         db.client,
+		bsonOpts:       db.bsonOpts,
 		registry:       db.registry,
 		streamType:     DatabaseStream,
 		databaseName:   db.Name(),