Method: AsyncCable::Registry#add

Defined in:

lib/async_cable/registry.rb

#add(channel_name, stream_name, connection) ⇒ Object

Adds connection to registry.

Parameters:

• channel_name (String)
• stream_name (String)
• connection (AsyncCable::Connection)

# File 'lib/async_cable/registry.rb', line 15

def add(channel_name, stream_name, connection)
  @mutex.synchronize do
    subscribers[channel_name][stream_name].push(connection)
    connection
  end
end