class PublishSubscribe::SubscriptionRegistry

Public Class Methods

new() click to toggle source
# File lib/publish_subscribe.rb, line 20
def initialize
  @subscriptions = {}
end

Public Instance Methods

add(channel, proc) click to toggle source
# File lib/publish_subscribe.rb, line 24
def add(channel, proc)
  (@subscriptions[channel] ||= []) << proc
end
get(channel) click to toggle source
# File lib/publish_subscribe.rb, line 28
def get(channel)
  @subscriptions[channel] || []
end