123456789_123456789_123456789_123456789_123456789_

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

Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Subclasses:
PostgreSQL::Listener, Redis::Listener
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, ::ActionCable::SubscriptionAdapter::SubscriberMap
Instance Chain:
self, ::ActionCable::SubscriptionAdapter::SubscriberMap
Inherits: ActionCable::SubscriptionAdapter::SubscriberMap
Defined in: actioncable/lib/action_cable/subscription_adapter/subscriber_map.rb

Class Method Summary

::ActionCable::SubscriptionAdapter::SubscriberMap - Inherited

.new

Instance Method Summary

::ActionCable::SubscriptionAdapter::SubscriberMap - Inherited

#add_channel, #add_subscriber, #broadcast, #invoke_callback, #remove_channel, #remove_subscriber

Constructor Details

.new(executor) ⇒ Async

[ GitHub ] 

  


# File 'actioncable/lib/action_cable/subscription_adapter/subscriber_map.rb', line 61



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


  







Instance Method Details



  

    #add_subscriber  
  

  [ GitHub ]


  

  


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



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


  








  

    #invoke_callback  
  

  [ GitHub ]


  

  


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



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


  








  

    #remove_subscriber  
  

  [ GitHub ]


  

  


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



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