class ActionCable::SubscriptionAdapter::Redis::Listener::SubscribedClient

def initialize(raw_client)
  @raw_client = raw_client
end

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

def subscribe(*channel)
  send_command("subscribe", *channel)
end

def unsubscribe(*channel)
  send_command("unsubscribe", *channel)
end