class ActiveJobChannel::Channel

Constants

CHANNEL_NAME

Public Instance Methods

subscribed() click to toggle source
# File lib/active_job_channel/channel.rb, line 7
def subscribed
  stream_from CHANNEL_NAME
  stream_from private_stream if connection.connection_identifier.present?
end

Private Instance Methods

private_stream() click to toggle source
# File lib/active_job_channel/channel.rb, line 14
def private_stream
  [CHANNEL_NAME, connection.connection_identifier].join('#')
end