123456789_123456789_123456789_123456789_123456789_

Class: ActionCable::SubscriptionAdapter::Base

Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Subclasses:
Async, Inline, PostgreSQL, 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)
  @executor = server.executor
  @config = server.config
end


  







Instance Attribute Details



  

    #config   (readonly, private)
  

  [ GitHub ]


  

  


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



attr_reader :executor, :config


  








  

    #executor   (readonly, private)
  

  [ GitHub ]


  

  


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



attr_reader :executor, :config


  








  

    #logger   (readonly)
  

  [ GitHub ]


  

  


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



delegate :logger, to: :config


  







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
  config.cable[:id] = "ActionCable-PID-#{$$}" unless config.cable.key?(:id)
  config.cable[:id]
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