aboutsummaryrefslogtreecommitdiffstats
path: root/activesupport/lib/active_support/notifications
diff options
context:
space:
mode:
Diffstat (limited to 'activesupport/lib/active_support/notifications')
-rw-r--r--activesupport/lib/active_support/notifications/fanout.rb10
1 files changed, 5 insertions, 5 deletions
diff --git a/activesupport/lib/active_support/notifications/fanout.rb b/activesupport/lib/active_support/notifications/fanout.rb
index 6e4ff40dc3..3bbb9cca44 100644
--- a/activesupport/lib/active_support/notifications/fanout.rb
+++ b/activesupport/lib/active_support/notifications/fanout.rb
@@ -8,9 +8,9 @@ module ActiveSupport
@listeners_for = {}
end
- def subscribe(pattern = nil, &block)
+ def subscribe(pattern = nil, block = Proc.new)
@listeners_for.clear
- Subscriber.new(pattern, &block).tap do |s|
+ Subscriber.new(pattern, block).tap do |s|
@subscribers << s
end
end
@@ -33,14 +33,14 @@ module ActiveSupport
end
class Subscriber #:nodoc:
- def initialize(pattern, &block)
+ def initialize(pattern, delegate)
@pattern = pattern
- @block = block
+ @delegate = delegate
end
def publish(*args)
return unless subscribed_to?(args.first)
- @block.call(*args)
+ @delegate.call(*args)
true
end