From 18dca47ea943be474a84850e1c6996a57e44fb13 Mon Sep 17 00:00:00 2001 From: Ivan Kalugin Date: Thu, 6 Feb 2025 16:33:24 +0100 Subject: [PATCH] fix database watch function didn't set bsonOpts for changeStreamConfig --- mongo/database.go | 1 + 1 file changed, 1 insertion(+) 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(),