diff --git a/mongo/options/changestreamoptions.go b/mongo/options/changestreamoptions.go index 2d9f95c14d..447f7c14cc 100644 --- a/mongo/options/changestreamoptions.go +++ b/mongo/options/changestreamoptions.go @@ -211,6 +211,9 @@ func MergeChangeStreamOptions(opts ...*ChangeStreamOptions) *ChangeStreamOptions if cso.CustomPipeline != nil { csOpts.CustomPipeline = cso.CustomPipeline } + if cso.CursorBatchSize != nil { + csOpts.CursorBatchSize = cso.CursorBatchSize + } } return csOpts