aboutsummaryrefslogtreecommitdiffstats
path: root/activesupport/lib/active_support/notifications
diff options
context:
space:
mode:
authorAaron Patterson <aaron.patterson@gmail.com>2010-07-17 14:35:44 -0700
committerAaron Patterson <aaron.patterson@gmail.com>2010-07-17 14:35:44 -0700
commit4226c93779dae53c6921f8ce93d6af000a24e2d1 (patch)
treee2c0d34c4ed59576c4d7e15efc8045a303689d96 /activesupport/lib/active_support/notifications
parent9c80f5b3910ca0573f6e40aaccf3102c260986b6 (diff)
downloadrails-4226c93779dae53c6921f8ce93d6af000a24e2d1.tar.gz
rails-4226c93779dae53c6921f8ce93d6af000a24e2d1.tar.bz2
rails-4226c93779dae53c6921f8ce93d6af000a24e2d1.zip
removing Binding class
Diffstat (limited to 'activesupport/lib/active_support/notifications')
-rw-r--r--activesupport/lib/active_support/notifications/fanout.rb18
1 files changed, 4 insertions, 14 deletions
diff --git a/activesupport/lib/active_support/notifications/fanout.rb b/activesupport/lib/active_support/notifications/fanout.rb
index b27713e4ad..fa469c8b79 100644
--- a/activesupport/lib/active_support/notifications/fanout.rb
+++ b/activesupport/lib/active_support/notifications/fanout.rb
@@ -6,13 +6,15 @@ module ActiveSupport
def initialize
@subscribers = []
@listeners_for = {}
+ @pattern = nil
end
def bind(pattern)
- Binding.new(self, pattern)
+ @pattern = pattern
+ self
end
- def subscribe(pattern = nil, &block)
+ def subscribe(pattern = @pattern, &block)
@listeners_for.clear
@subscribers << Subscriber.new(pattern, &block)
@subscribers.last
@@ -35,18 +37,6 @@ module ActiveSupport
def wait
end
- # Used for internal implementation only.
- class Binding #:nodoc:
- def initialize(queue, pattern)
- @queue = queue
- @pattern = pattern
- end
-
- def subscribe(&block)
- @queue.subscribe(@pattern, &block)
- end
- end
-
class Subscriber #:nodoc:
def initialize(pattern, &block)
@pattern = pattern