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)