Method: ActionCable::Channel::Base#initialize

Defined in:
actioncable/lib/action_cable/channel/base.rb

#initialize(connection, identifier, params = {}) ⇒ Base

Returns a new instance of Base.



156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
 
# File 'actioncable/lib/action_cable/channel/base.rb', line 156

def initialize(connection, identifier, params = {})
  @connection = connection
  @identifier = identifier
  @params     = params

  # When a channel is streaming via pubsub, we want to delay the confirmation
  # transmission until pubsub subscription is confirmed.
  #
  # The counter starts at 1 because it's awaiting a call to #subscribe_to_channel
  @defer_subscription_confirmation_counter = Concurrent::AtomicFixnum.new(1)

  @reject_subscription = nil
  @subscription_confirmation_sent = nil

  delegate_connection_identifiers
end