class Redis::Subscription

def initialize
  @callbacks = Hash.new do |hash, key|
    hash[key] = lambda { |*_| }
  end
  yield(self)
end

def message(&block)
  @callbacks["message"] = block
end

def pmessage(&block)
  @callbacks["pmessage"] = block
end

def psubscribe(&block)
  @callbacks["psubscribe"] = block
end

def punsubscribe(&block)
  @callbacks["punsubscribe"] = block
end

def subscribe(&block)
  @callbacks["subscribe"] = block
end

def unsubscribe(&block)
  @callbacks["unsubscribe"] = block
end