Method: Circuitry::Processors::Batcher.flush

Defined in:
lib/circuitry/processors/batcher.rb

.flushObject



14
15
16
17
18
# File 'lib/circuitry/processors/batcher.rb', line 14

def flush
  while (block = pool.shift)
    safely_process(&block)
  end
end