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
- .new(server) ⇒ Base constructor
Instance Attribute Summary
Instance Method Summary
Constructor Details
.new(server) ⇒ Base
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)
# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 13
def broadcast(channel, payload) raise NotImplementedError end
#identifier
[ GitHub ]# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 29
def identifier @server.config.cable[:id] ||= "ActionCable-PID-#{$$}" end
#shutdown
# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 25
def shutdown raise NotImplementedError end
#subscribe(channel, message_callback, success_callback = nil)
# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 17
def subscribe(channel, , success_callback = nil) raise NotImplementedError end
#unsubscribe(channel, message_callback)
# File 'actioncable/lib/action_cable/subscription_adapter/base.rb', line 21
def unsubscribe(channel, ) raise NotImplementedError end