lib/mongo/collection/view/change_stream.rb in mongo-2.7.0.rc0 vs lib/mongo/collection/view/change_stream.rb in mongo-2.7.0
- old
+ new
@@ -167,9 +167,10 @@
# Any errors here will stop iteration and break out of this
# method
close
create_cursor!
retried = false
+ doc = @cursor.try_next
else
# Attempt to retry a getMore once
retried = true
retry
end