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)