lib/acfs/runner.rb in acfs-0.40.1.rc1 vs lib/acfs/runner.rb in acfs-0.41.0

- old
+ new

@@ -57,26 +57,30 @@ # def start return if running? enqueue_operations - - @running = true - adapter.start + start_all rescue queue.clear raise - ensure - @running = false end def clear queue.clear adapter.abort @running = false end private + + def start_all + @running = true + adapter.start + ensure + @running = false + end + def enqueue_operations while (op = queue.shift) op_request(op) { |req| adapter.queue req } end end