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, Test
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 10



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 8



attr_reader :logger, :server


  








  

    #server   (readonly)
  

  [ GitHub ]


  

  


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



attr_reader :logger, :server


  







Instance Method Details



  

    #broadcast(channel, payload)  
  



  

    
  





  
Raises:


    
  
  • 
    (NotImplementedError)
  
    • 





  [ GitHub ]


  

  


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



def broadcast(channel, payload)
  raise NotImplementedError
end


  








  

    #identifier  
  

  [ GitHub ]


  

  


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



def identifier
  @server.config.cable[:id] ||= "ActionCable-PID-#{$$}"
end


  








  

    #shutdown  
  



  

    
  





  
Raises:


    
  
  • 
    (NotImplementedError)
  
    • 





  [ GitHub ]


  

  


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



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 19



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 23



def unsubscribe(channel, message_callback)
  raise NotImplementedError
end