test/functional/concurrent_base.rb in ruote-2.1.11 vs test/functional/concurrent_base.rb in ruote-2.2.0

- old
+ new

@@ -18,14 +18,14 @@ def peek_msg @msgs = @context.storage.get_msgs if ( ! @msgs) || @msgs.size < 1 @msgs.shift end - def do_process (msg) + def do_process(msg) @context.worker.process(msg) end - def step (count) + def step(count) return if count == 0 loop do m = next_msg next unless m do_process(m)