Class: AnyCable::Rails::PubSubChannel

Inherits:
ActionCable::Channel::Base
  • Object
show all
Defined in:
lib/anycable/rails/pubsub_channel.rb

Instance Method Summary collapse

Instance Method Details

#subscribed ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/anycable/rails/pubsub_channel.rb', line 6

def subscribed
  stream_name =
    if params[:stream_name] && connection.allow_public_streams?
      params[:stream_name]
    elsif params[:signed_stream_name]
      AnyCable::Streams.verified(params[:signed_stream_name])
    end

  if stream_name
    stream_from stream_name
  else
    reject
  end
end