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

Inherits:

SubscriberMap

• Object
• SubscriberMap
• ActionCable::SubscriptionAdapter::Async::AsyncSubscriberMap

Defined in:

actioncable/lib/action_cable/subscription_adapter/async.rb

Instance Method Summary

• #add_subscriber ⇒ Object
• #initialize(event_loop) ⇒ AsyncSubscriberMap constructor

  A new instance of AsyncSubscriberMap.

• #invoke_callback ⇒ Object

Methods inherited from SubscriberMap

#add_channel, #broadcast, #remove_channel, #remove_subscriber

Constructor Details

#initialize(event_loop) ⇒ AsyncSubscriberMap

Returns a new instance of AsyncSubscriberMap.

# 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

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

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

#invoke_callback ⇒ Object

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

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