123456789_123456789_123456789_123456789_123456789_

Class: ActionCable::SubscriptionAdapter::Base

Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Subclasses:
ActionCable::SubscriptionAdapter::Async, ActionCable::SubscriptionAdapter::Inline, ActionCable::SubscriptionAdapter::PostgreSQL, ActionCable::SubscriptionAdapter::Redis
Inherits: Object
Defined in: actioncable/lib/action_cable/subscription_adapter/base.rb

Class Method Summary

Instance Attribute Summary

Instance Method Summary

Constructor Details

.new(server) ⇒ Base

[ GitHub ] 

  


# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 8



def initialize(server)
  @server = server
  @logger = @server.logger
end


  







Instance Attribute Details



  

    #logger   (readonly)
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 6



attr_reader :logger, :server


  








  

    #server   (readonly)
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 6



attr_reader :logger, :server


  







Instance Method Details



  

    #broadcast(channel, payload)  
  



  

    
  





  
Raises:


    
  
  • 
    (NotImplementedError)
  
    • 





  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 13



def broadcast(channel, payload)
  raise NotImplementedError
end


  








  

    #shutdown  
  



  

    
  





  
Raises:


    
  
  • 
    (NotImplementedError)
  
    • 





  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 25



def shutdown
  raise NotImplementedError
end


  








  

    #subscribe(channel, message_callback, success_callback = nil)  
  



  

    
  





  
Raises:


    
  
  • 
    (NotImplementedError)
  
    • 





  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 17



def subscribe(channel, message_callback, success_callback = nil)
  raise NotImplementedError
end


  








  

    #unsubscribe(channel, message_callback)  
  



  

    
  





  
Raises:


    
  
  • 
    (NotImplementedError)
  
    • 





  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 21



def unsubscribe(channel, message_callback)
  raise NotImplementedError
end