Class: ActionCable::SubscriptionAdapter::Async::AsyncSubscriberMap

Inherits:
SubscriberMap show all
Defined in:
actioncable/lib/action_cable/subscription_adapter/async.rb

Instance Method Summary collapse

Methods inherited from SubscriberMap

#add_channel, #broadcast, #remove_channel, #remove_subscriber

Constructor Details

#initialize(event_loop) ⇒ AsyncSubscriberMap 



14
15
16
17
 
# File 'actioncable/lib/action_cable/subscription_adapter/async.rb', line 14

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

Instance Method Details

#add_subscriber ⇒ Object 



19
20
21
 
# File 'actioncable/lib/action_cable/subscription_adapter/async.rb', line 19

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

#invoke_callback ⇒ Object 



23
24
25
 
# File 'actioncable/lib/action_cable/subscription_adapter/async.rb', line 23

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