class ActionCable::SubscriptionAdapter::SubscriberMap
Public Class Methods
# File actioncable/lib/action_cable/subscription_adapter/subscriber_map.rb, line 6 def initialize @subscribers = Hash.new { |h, k| h[k] = [] } @sync = Mutex.new end
Public Instance Methods
# File actioncable/lib/action_cable/subscription_adapter/subscriber_map.rb, line 47 def add_channel(channel, on_success) on_success.call if on_success end
# File actioncable/lib/action_cable/subscription_adapter/subscriber_map.rb, line 11 def add_subscriber(channel, subscriber, on_success) @sync.synchronize do new_channel = !@subscribers.key?(channel) @subscribers[channel] << subscriber if new_channel add_channel channel, on_success elsif on_success on_success.call end end end
# File actioncable/lib/action_cable/subscription_adapter/subscriber_map.rb, line 36 def broadcast(channel, message) list = @sync.synchronize do return if !@subscribers.key?(channel) @subscribers[channel].dup end list.each do |subscriber| invoke_callback(subscriber, message) end end
# File actioncable/lib/action_cable/subscription_adapter/subscriber_map.rb, line 54 def invoke_callback(callback, message) callback.call message end
# File actioncable/lib/action_cable/subscription_adapter/subscriber_map.rb, line 51 def remove_channel(channel) end
# File actioncable/lib/action_cable/subscription_adapter/subscriber_map.rb, line 25 def remove_subscriber(channel, subscriber) @sync.synchronize do @subscribers[channel].delete(subscriber) if @subscribers[channel].empty? @subscribers.delete channel remove_channel channel end end end