class Redis::Client::ThreadSafe

def ensure_connected(&block)

def ensure_connected(&block)
  super do
    synchronize(&block)
  end
end