class Redis::Client

def call_with_timeout(command, extra_timeout, &blk) 

def call_with_timeout(command, extra_timeout, &blk)
  timeout = extra_timeout == 0 ? 0 : self.timeout + extra_timeout
  with_socket_timeout(timeout) do
    call(command, &blk)
  end
rescue ConnectionError
  retry
end