Method: AsyncCable::Registry#each

Defined in:
lib/async_cable/registry.rb

#each(channel_name = nil, stream_name = nil, &block) ⇒ Object

Iterate connections asynchronously.

Parameters:

  • channel_name (String, NilClass) (defaults to: nil)
  • stream_name (String, NilClass) (defaults to: nil) 


52
53
54
55
 
# File 'lib/async_cable/registry.rb', line 52

def each(channel_name = nil, stream_name = nil, &block)
  list = find(channel_name, stream_name)
  Util.each_async(list, &block)
end