module ActiveWorker::Behavior::CanBeNotified::ClassMethods
Constants
- SLEEP_DURATION
Public Instance Methods
process_notifications(initial_configuration, thread_expanded_configurations)
click to toggle source
# File lib/active_worker/behavior/can_be_notified.rb, line 8 def process_notifications(initial_configuration, thread_expanded_configurations) if initial_configuration.wait_for_notifications sleep SLEEP_DURATION until initial_configuration.notified? thread_expanded_configurations.map(&:notify) end end