class ActionCable::SubscriptionAdapter::Redis::Listener::SubscribedClient
Public Class Methods
Source
# File lib/action_cable/subscription_adapter/redis.rb, line 215 def initialize(raw_client) @raw_client = raw_client end
Public Instance Methods
Source
# File lib/action_cable/subscription_adapter/redis.rb, line 219 def subscribe(*channel) send_command("subscribe", *channel) end
Source
# File lib/action_cable/subscription_adapter/redis.rb, line 223 def unsubscribe(*channel) send_command("unsubscribe", *channel) end
Private Instance Methods
Source
# File lib/action_cable/subscription_adapter/redis.rb, line 228 def send_command(*command) @raw_client.write(command) very_raw_connection = @raw_client.connection.instance_variable_defined?(:@connection) && @raw_client.connection.instance_variable_get(:@connection) if very_raw_connection && very_raw_connection.respond_to?(:flush) very_raw_connection.flush end nil end