Merge pull request globalsign#24 from joomcode/hotfix/add-cursor-maxtime-in-change-stream

rihter007 · web-flow · commit eebe5c97f713 · 2019-12-31T12:45:17.000+03:00
Propagate timeout to cursor in collection Watch
diff --git a/changestreams.go b/changestreams.go
@@ -67,6 +67,7 @@ func (coll *Collection) Watch(pipeline interface{},
 	csPipe := constructChangeStreamPipeline(pipeline, options)
 	pipe := coll.Pipe(&csPipe)
 	if options.MaxAwaitTimeMS > 0 {
+		pipe.SetCursorMaxTime(options.MaxAwaitTimeMS)
 		pipe.SetMaxTime(options.MaxAwaitTimeMS)
 	}
 	if options.BatchSize > 0 {

Original file line number	Diff line number	Diff line change
`@@ -67,6 +67,7 @@ func (coll *Collection) Watch(pipeline interface{},`
`67`	`67`	`csPipe := constructChangeStreamPipeline(pipeline, options)`
`68`	`68`	`pipe := coll.Pipe(&csPipe)`
`69`	`69`	`if options.MaxAwaitTimeMS > 0 {`
	`70`	`+ pipe.SetCursorMaxTime(options.MaxAwaitTimeMS)`
`70`	`71`	`pipe.SetMaxTime(options.MaxAwaitTimeMS)`
`71`	`72`	`}`
`72`	`73`	`if options.BatchSize > 0 {`