Method: ConcurrentWorker::Worker#call_retired_callbacks

Defined in:
lib/concurrent_worker/worker.rb

#call_retired_callbacks ⇒ Object 



81
82
83
84
85
86
87
 
# File 'lib/concurrent_worker/worker.rb', line 81

def call_retired_callbacks
  Thread.handle_interrupt(Object => @options[:retired_callback_interrupt]) do
    @retired_callbacks.each do |callback|
      callback.call
    end
  end
end