Class: ActiveSupport::Notifications::Fanout::Binding

Inherits:
Object
  • Object
show all
Defined in:
lib/active_support/notifications/fanout.rb

Overview

Used for internal implementation only.

Instance Method Summary collapse

Constructor Details

#initialize(queue, pattern) ⇒ Binding

:nodoc:



40
41
42
43
44
45
46
47
48
49
 
# File 'lib/active_support/notifications/fanout.rb', line 40

def initialize(queue, pattern)
  @queue = queue
  @pattern =
    case pattern
    when Regexp, NilClass
      pattern
    else
      /^#{Regexp.escape(pattern.to_s)}$/
    end
end

Instance Method Details

#subscribe(&block) ⇒ Object 



51
52
53
 
# File 'lib/active_support/notifications/fanout.rb', line 51

def subscribe(&block)
  @queue.subscribe(@pattern, &block)
end