module PublishSubscribe

Public Instance Methods

subscribe(channel, &block) click to toggle source 
# File lib/publish_subscribe.rb, line 3
def subscribe(channel, &block)
  subscriptions.add(channel, block)
end

Private Instance Methods

publish(channel, *args) click to toggle source 
# File lib/publish_subscribe.rb, line 9
def publish(channel, *args)
  subscriptions.get(channel).each do |proc|
    proc.call(*args)
  end
end
subscriptions() click to toggle source 
# File lib/publish_subscribe.rb, line 15
def subscriptions
  @_subscriptions ||= SubscriptionRegistry.new
end