Module: ActiveWorker::Behavior::CanBeNotified::ClassMethods

Defined in:
lib/active_worker/behavior/can_be_notified.rb

Constant Summary collapse

SLEEP_DURATION = 
5

Instance Method Summary collapse

Instance Method Details

#process_notifications(initial_configuration, thread_expanded_configurations) ⇒ Object 



8
9
10
11
12
13
 
# 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