lib/acfs/runner.rb in acfs-0.42.0 vs lib/acfs/runner.rb in acfs-0.43.0

@@ -1,9 +1,8 @@
 require 'acfs/service/middleware'
 
 module Acfs
-
   # @api private
   #
   class Runner
     include Service::Middleware
     attr_reader :adapter
@@ -23,11 +22,11 @@
 
     # Run operation right now skipping queue.
     #
     def run(op)
       ::ActiveSupport::Notifications.instrument 'acfs.runner.sync_run', operation: op do
-        op_request(op) { |req| adapter.run req }
+        op_request(op) {|req| adapter.run req }
       end
     end
 
     # List of current queued operations.
     #
@@ -38,11 +37,11 @@
     # Enqueue operation to be run later.
     #
     def enqueue(op)
       ::ActiveSupport::Notifications.instrument 'acfs.runner.enqueue', operation: op do
         if running?
-          op_request(op) { |req| adapter.queue req }
+          op_request(op) {|req| adapter.queue req }
         else
           queue << op
         end
       end
     end
@@ -80,15 +79,15 @@
       @running = false
     end
 
     def enqueue_operations
       while (op = queue.shift)
-        op_request(op) { |req| adapter.queue req }
+        op_request(op) {|req| adapter.queue req }
       end
     end
 
     def op_request(op)
-      return if Acfs::Stub.enabled? and Acfs::Stub.stubbed(op)
+      return if Acfs::Stub.enabled? && Acfs::Stub.stubbed(op)
       req = op.service.prepare op.request
       return unless req.is_a? Acfs::Request
       req = prepare req
       return unless req.is_a? Acfs::Request
       yield req