# File lib/redis/connection/synchrony.rb, line 26 def receive_data(data) @reader.feed(data) begin until (reply = @reader.gets) == false @req.succeed [:reply, reply] end rescue RuntimeError => err @req.fail [:error, ::Redis::ProtocolError.new(err.message)] end end