Skip to content

Commit 18dca47

Browse files
committed
fix database watch function didn't set bsonOpts for changeStreamConfig
1 parent f30efd2 commit 18dca47

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

mongo/database.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -574,6 +574,7 @@ func (db *Database) Watch(ctx context.Context, pipeline interface{},
574574
readConcern: db.readConcern,
575575
readPreference: db.readPreference,
576576
client: db.client,
577+
bsonOpts: db.bsonOpts,
577578
registry: db.registry,
578579
streamType: DatabaseStream,
579580
databaseName: db.Name(),

0 commit comments

Comments
 (0)