class Redis::Client::ThreadSafe

def ensure_connected(&block)

def ensure_connected(&block)
  synchronize { super }
end