# File lib/tarantool/em_db.rb, line 77 def call(result=INITIAL) result = _parse_iproto(result) unless result == INITIAL case result when INITIAL, ::IProto::ConnectionError begin if (@i += 1) >= @replicas.size EM.next_tick Curry1.new(@feed, ConnectionError.new("no available connections")) return end end until (repl = @replicas[@i]).could_be_connected? repl.send_request(@response.request_type, @response.body, self) when Exception @feed.call result else @feed.call @response.parse_response(result) end end
Generated with the Darkfish Rdoc Generator 2.