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