Method: AsyncCable::Registry#remove

Defined in:

lib/async_cable/registry.rb

#remove(channel_name, stream_name, connection) ⇒ Object

Removes connection from registry.

Parameters:

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

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

def remove(channel_name, stream_name, connection)
  @mutex.synchronize do
    subscribers[channel_name][stream_name].delete(connection)
    subscribers[channel_name].delete(stream_name) if subscribers[channel_name][stream_name].empty?
    connection
  end
end