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