Method: Webhookdb::Concurrent::ParallelizedPool#join

Defined in:
lib/webhookdb/concurrent.rb

#join ⇒ Object

Raises:

  • (@exception) 


88
89
90
91
92
 
# File 'lib/webhookdb/concurrent.rb', line 88

def join
  @queue.push(STOP)
  @threads.each(&:join)
  raise @exception if @exception
end