lib/acfs/global.rb in acfs-0.39.1 vs lib/acfs/global.rb in acfs-0.40.0

@@ -1,16 +1,16 @@
 module Acfs
-
+  #
   # Global Acfs module methods.
   #
   module Global
-
+    #
     # @api private
     # @return [Runner]
     #
     def runner
-      @runner ||= Runner.new Adapter::Typhoeus.new
+      Thread.current[:acfs_runner] ||= Runner.new Adapter::Typhoeus.new
     end
 
     # @api public
     #
     # Run all queued operations.
@@ -30,38 +30,41 @@
     #
     # @return [undefined]
     # @see Configuration#configure
     #
     def configure(&block)
-      Configuration.current.configure &block
+      Configuration.current.configure(&block)
     end
 
     # @api public
     #
     # Reset all queues, stubs and internal state.
     #
     def reset
       ::ActiveSupport::Notifications.instrument 'acfs.reset' do
-        self.runner.clear
+        runner.clear
         Acfs::Stub.clear
       end
     end
 
     # @api public
     #
     # Add an additional callback hook to not loaded resource.
     # If given resource already loaded callback will be invoked immediately.
     #
-    # This method will be replaced by explicit callback handling when query methods
-    # return explicit future objects.
+    # This method will be replaced by explicit callback
+    # handling when query methods return explicit future objects.
     #
     # @example
     #   user = MyUser.find 1, &callback_one
     #   Acfs.add_callback(user, &callback_two)
     #
     def add_callback(resource, &block)
-      raise ArgumentError.new "Given resource is not an Acfs resource but a: #{resource.class.name}" unless resource.respond_to?(:__callbacks__)
+      unless resource.respond_to?(:__callbacks__)
+        raise ArgumentError.new 'Given resource is not an Acfs resource ' \
+          "delegator but a: #{resource.class.name}"
+      end
       return false if block.nil?
 
       if resource.loaded?
         block.call resource
       else
@@ -69,11 +72,11 @@
       end
     end
 
     def on(*resources)
       resources.each do |resource|
-        add_callback resource do |ret|
-          yield(*resources) unless resources.any? { |res| !res.loaded? }
+        add_callback resource do |_|
+          yield(*resources) unless resources.any?{|res| !res.loaded? }
         end
       end
     end
   end
 end