Class: Spree::Event::SubscriberRegistry
- Inherits:
-
Object
- Object
- Spree::Event::SubscriberRegistry
- Defined in:
- lib/spree/event/subscriber_registry.rb
Instance Method Summary collapse
- #activate_all_subscribers ⇒ Object
- #activate_autoloadable_subscribers ⇒ Object
- #activate_subscriber(subscriber) ⇒ Object
- #deactivate_all_subscribers ⇒ Object
- #deactivate_subscriber(subscriber, event_action_name = nil) ⇒ Object
-
#initialize ⇒ SubscriberRegistry
constructor
A new instance of SubscriberRegistry.
- #register(subscriber) ⇒ Object
Constructor Details
#initialize ⇒ SubscriberRegistry
Returns a new instance of SubscriberRegistry.
6 7 8 9 |
# File 'lib/spree/event/subscriber_registry.rb', line 6 def initialize @registry = {} @semaphore = Mutex.new end |
Instance Method Details
#activate_all_subscribers ⇒ Object
20 21 22 |
# File 'lib/spree/event/subscriber_registry.rb', line 20 def activate_all_subscribers registry.each_key { |subscriber_name| activate_subscriber(subscriber_name.constantize) } end |
#activate_autoloadable_subscribers ⇒ Object
15 16 17 18 |
# File 'lib/spree/event/subscriber_registry.rb', line 15 def activate_autoloadable_subscribers require_subscriber_files activate_all_subscribers end |
#activate_subscriber(subscriber) ⇒ Object
28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 |
# File 'lib/spree/event/subscriber_registry.rb', line 28 def activate_subscriber(subscriber) return unless registry[subscriber.name] subscriber.event_actions.each do |event_action, event_name| @semaphore.synchronize do unsafe_deactivate_subscriber(subscriber, event_action) subscription = Spree::Event.subscribe(event_name) { |event| subscriber.send(event_action, event) } # deprecated mappings, to be removed when Solidus 2.10 is not supported anymore: subscriber.send("#{event_action}_handler=", subscription) registry[subscriber.name][event_action] = subscription end end end |
#deactivate_all_subscribers ⇒ Object
24 25 26 |
# File 'lib/spree/event/subscriber_registry.rb', line 24 def deactivate_all_subscribers registry.each_key { |subscriber_name| deactivate_subscriber(subscriber_name.constantize) } end |
#deactivate_subscriber(subscriber, event_action_name = nil) ⇒ Object
45 46 47 48 49 |
# File 'lib/spree/event/subscriber_registry.rb', line 45 def deactivate_subscriber(subscriber, event_action_name = nil) @semaphore.synchronize do unsafe_deactivate_subscriber(subscriber, event_action_name) end end |
#register(subscriber) ⇒ Object
11 12 13 |
# File 'lib/spree/event/subscriber_registry.rb', line 11 def register(subscriber) registry[subscriber.name] ||= {} end |