Source: show | on GitHub
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 10 def initialize(server) @executor = server.executor @config = server.config end
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 15 def broadcast(channel, payload) raise NotImplementedError end
# 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
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 27 def shutdown raise NotImplementedError end
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 19 def subscribe(channel, message_callback, success_callback = nil) raise NotImplementedError end
# File actioncable/lib/action_cable/subscription_adapter/base.rb, line 23 def unsubscribe(channel, message_callback) raise NotImplementedError end