Details
-
Bug
-
Resolution: Fixed
-
Major - P3
-
0.3.0
-
None
-
None
Description
I could be doing something wrong, but it appears that the maxAwaitTimeMS on a change stream is not always getting converted to maxTimeMs before being sent on the wire.
var stream *mongo.ChangeStream
|
opts := options.ChangeStream()
|
opts.SetMaxAwaitTime(time.Duration(10) * time.Second) |
opts.SetFullDocument(options.UpdateLookup)
|
opts.SetStartAtOperationTime(startAt)
|
c := client.Database("test").Collection("test") |
stream, err = c.Watch(context.Background(), pipeline, opts)
|
With SetMaxAwaitTime applied I get the following error:
BSON field '$changeStream.maxAwaitTimeMS' is an unknown field