Method: Async::WorkerPool::Worker#run

Defined in:
lib/async/worker_pool.rb

#run ⇒ Object

Execute work until the queue is closed.


114
115
116
117
118
 
# File 'lib/async/worker_pool.rb', line 114

def run
	while work = @work.pop
		work.call
	end
end