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