Method: ConcurrentWorker::Worker#req_counter_close

Defined in:
lib/concurrent_worker/worker.rb

#req_counter_close ⇒ Object 



89
90
91
92
93
94
 
# File 'lib/concurrent_worker/worker.rb', line 89

def req_counter_close
  @req_counter.close
  until @req_counter.empty?
    @undone_requests.push(@req_counter.pop)
  end
end