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.



76
77
78
79
 
# File 'lib/action_cable/subscription_adapter/subscriber_map.rb', line 76

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

Instance Method Details

#add_subscriber ⇒ Object 



81
82
83
 
# File 'lib/action_cable/subscription_adapter/subscriber_map.rb', line 81

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

#invoke_callback ⇒ Object 



89
90
91
 
# File 'lib/action_cable/subscription_adapter/subscriber_map.rb', line 89

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

#remove_subscriber ⇒ Object 



85
86
87
 
# File 'lib/action_cable/subscription_adapter/subscriber_map.rb', line 85

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