lib/mongo/collection/view/change_stream.rb in mongo-2.5.1 vs lib/mongo/collection/view/change_stream.rb in mongo-2.5.2
- old
+ new
@@ -151,10 +151,10 @@
end
end
def create_cursor!
session = client.send(:get_session, @options)
- server = server_selector.select_server(cluster, false)
+ server = server_selector.select_server(cluster)
result = send_initial_query(server, session)
@cursor = Cursor.new(view, result, server, disable_retry: true, session: session)
end
def pipeline