class Redis::Connection::RedisClient

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