class Redis::Client

def ensure_connected

def ensure_connected
  connect unless connected?
  begin
    yield
  rescue Errno::ECONNRESET, Errno::EPIPE, Errno::ECONNABORTED
    if reconnect
      yield
    else
      raise Errno::ECONNRESET
    end
  end
end