class Redis

def subscribed?
  synchronize do |client|
    client.kind_of? SubscribedClient
  end
end