method
new
rails latest stable - Class:
ActionCable::SubscriptionAdapter::Redis::Listener
new(adapter, config_options, event_loop)public
No documentation available.
# File actioncable/lib/action_cable/subscription_adapter/redis.rb, line 65
def initialize(adapter, config_options, event_loop)
super()
@adapter = adapter
@event_loop = event_loop
@subscribe_callbacks = Hash.new { |h, k| h[k] = [] }
@subscription_lock = Mutex.new
@reconnect_attempt = 0
# Use the same config as used by Redis conn
@reconnect_attempts = config_options.fetch(:reconnect_attempts, 1)
@reconnect_attempts = Array.new(@reconnect_attempts, 0) if @reconnect_attempts.is_a?(Integer)
@subscribed_client = nil
@when_connected = []
@thread = nil
end