module Semian::Instrumentable

def notify(*args)
  subscribers.values.each { |subscriber| subscriber.call(*args) }
end

def subscribe(name = rand, &block)
  subscribers[name] = block
  name
end

def subscribers
  @subscribers ||= {}
end

def unsubscribe(name)
  subscribers.delete(name)
end