class Redis::Distributed

def psubscribe(*channels, &block)

def psubscribe(*channels, &block)
  raise NotImplementedError
end