Class: ActionCable::SubscriptionAdapter::SubscriberMap::Async

Inherits:
ActionCable::SubscriptionAdapter::SubscriberMap show all
Defined in:
lib/action_cable/subscription_adapter/subscriber_map.rb

Direct Known Subclasses

PostgreSQL::Listener, Redis::Listener

Instance Method Summary collapse

Methods inherited from ActionCable::SubscriptionAdapter::SubscriberMap

#add_channel, #broadcast, #remove_channel

Constructor Details

#initialize(executor) ⇒ Async

Returns a new instance of Async.



61
62
63
64
 
# File 'lib/action_cable/subscription_adapter/subscriber_map.rb', line 61

def initialize(executor)
  @executor = executor
  super()
end

Instance Method Details

#add_subscriber ⇒ Object 



66
67
68
 
# File 'lib/action_cable/subscription_adapter/subscriber_map.rb', line 66

def add_subscriber(*)
  @executor.post { super }
end

#invoke_callback ⇒ Object 



74
75
76
 
# File 'lib/action_cable/subscription_adapter/subscriber_map.rb', line 74

def invoke_callback(*)
  @executor.post { super }
end

#remove_subscriber ⇒ Object 



70
71
72
 
# File 'lib/action_cable/subscription_adapter/subscriber_map.rb', line 70

def remove_subscriber(*)
  @executor.post { super }
end