-
Type:
Bug
-
Resolution: Fixed
-
Priority:
Major - P3
-
Affects Version/s: 0.3.0
-
Component/s: None
-
Labels:None
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