# File lib/mongo/collection/view/map_reduce.rb, line 67 def each @cursor = nil session = client.send(:get_session, @options) legacy_write_with_retry do |server| result = send_initial_query(server, session) result = send_fetch_query(server, session) unless inline? @cursor = Cursor.new(view, result, server, session: session) end @cursor.each do |doc| yield doc end if block_given? @cursor.to_enum end