lib/acfs/runner.rb in acfs-0.16.0 vs lib/acfs/runner.rb in acfs-0.17.0

- old
+ new

@@ -1,9 +1,11 @@ require 'acfs/service/middleware' module Acfs + # @api private + # class Runner include Service::Middleware attr_reader :adapter def initialize(adapter) @@ -57,9 +59,10 @@ end def clear queue.clear adapter.abort + @running = false end private def enqueue_operations while (op = queue.shift)