Source: show | on GitHub
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 8 def initialize(server) @executor = server.executor @config = server.config end
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 13 def broadcast(channel, payload) raise NotImplementedError end
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 29 def identifier config.cable[:id] = "ActionCable-PID-#{$$}" unless config.cable.key?(:id) config.cable[:id] end
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 25 def shutdown raise NotImplementedError end
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 17 def subscribe(channel, message_callback, success_callback = nil) raise NotImplementedError end
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 21 def unsubscribe(channel, message_callback) raise NotImplementedError end