Skip to content

Commit c817cad

Browse files
committed
fixup! Add Iter.NextWithTimeout
1 parent 1693c1e commit c817cad

File tree

1 file changed

+0
-5
lines changed

1 file changed

+0
-5
lines changed

session.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -4372,11 +4372,6 @@ func (iter *Iter) NextWithTimeout(result interface{}, timeout time.Duration) boo
43724372
iter.m.Lock()
43734373
iter.timedout = false
43744374
deadline := time.Time{}
4375-
// for a ChangeStream iterator we have to call getMore before the loop otherwise
4376-
// we'll always return false
4377-
if iter.isChangeStream {
4378-
iter.getMore()
4379-
}
43804375
// check should we expect more data.
43814376
for iter.err == nil && iter.docData.Len() == 0 && (iter.docsToReceive > 0 || iter.op.cursorId != 0) {
43824377
// we should expect more data.

0 commit comments

Comments
 (0)