whitespace

Author: pitr-ch

lib/concurrent/agent.rb

@@ -164,7 +164,7 @@ def <<(block)
     # @!visibility private
     def try_rescue(ex) # :nodoc:
       rescuer = mutex.synchronize do
-        @rescuers.find{|r| ex.is_a?(r.clazz) }
+        @rescuers.find { |r| ex.is_a?(r.clazz) }
       end
       rescuer.block.call(ex) if rescuer
     rescue Exception => ex

spec/concurrent/agent_spec.rb

@@ -34,18 +34,18 @@ def dereferenceable_observable(opts = {})
       end
 
       def execute_dereferenceable(subject)
-        subject.post{|value| 10 }
+        subject.post { |value| 10 }
         sleep(0.1)
       end
 
       it_should_behave_like :dereferenceable
 
       # observable
-      
-      subject{ Agent.new(0) }
-      
+
+      subject { Agent.new(0) }
+
       def trigger_observable(observable)
-        observable.post{ nil }
+        observable.post { nil }
         sleep(0.1)
       end
 
@@ -71,25 +71,25 @@ def trigger_observable(observable)
       it 'uses the executor given with the :executor option' do
         executor.should_receive(:post).with(any_args).and_return(0)
         agent = Agent.new(0, executor: executor)
-        agent.post{|value| 0 }
+        agent.post { |value| 0 }
       end
 
       it 'uses the global operation pool when :operation is true' do
         Concurrent.configuration.should_receive(:global_operation_pool).and_return(executor)
         agent = Agent.new(0, operation: true)
-        agent.post{|value| 0 }
+        agent.post { |value| 0 }
       end
 
       it 'uses the global task pool when :task is true' do
         Concurrent.configuration.should_receive(:global_task_pool).and_return(executor)
         agent = Agent.new(0, task: true)
-        agent.post{|value| 0 }
+        agent.post { |value| 0 }
       end
 
       it 'uses the global task pool by default' do
         Concurrent.configuration.should_receive(:global_task_pool).and_return(executor)
         agent = Agent.new(0)
-        agent.post{|value| 0 }
+        agent.post { |value| 0 }
       end
     end
 
@@ -245,85 +245,85 @@ def trigger_observable(observable)
       it 'calls the first exception block with a matching class' do
         @expected = nil
         subject.
-      rescue(StandardError) { |ex| @expected = 1 }.
-        rescue(StandardError) { |ex| @expected = 2 }.
-        rescue(StandardError) { |ex| @expected = 3 }
-          subject.post { raise StandardError }
-          sleep(0.1)
-          @expected.should eq 1
-        end
+            rescue(StandardError) { |ex| @expected = 1 }.
+            rescue(StandardError) { |ex| @expected = 2 }.
+            rescue(StandardError) { |ex| @expected = 3 }
+        subject.post { raise StandardError }
+        sleep(0.1)
+        @expected.should eq 1
+      end
 
       it 'matches all with a rescue with no class given' do
         @expected = nil
         subject.
-      rescue(LoadError) { |ex| @expected = 1 }.
-        rescue { |ex| @expected = 2 }.
-        rescue(StandardError) { |ex| @expected = 3 }
-          subject.post { raise NoMethodError }
-          sleep(0.1)
-          @expected.should eq 2
-        end
+            rescue(LoadError) { |ex| @expected = 1 }.
+            rescue { |ex| @expected = 2 }.
+            rescue(StandardError) { |ex| @expected = 3 }
+        subject.post { raise NoMethodError }
+        sleep(0.1)
+        @expected.should eq 2
+      end
 
       it 'searches associated rescue handlers in order' do
         @expected = nil
         subject.
-      rescue(ArgumentError) { |ex| @expected = 1 }.
-        rescue(LoadError) { |ex| @expected = 2 }.
-        rescue(StandardError) { |ex| @expected = 3 }
-          subject.post { raise ArgumentError }
-          sleep(0.1)
-          @expected.should eq 1
+            rescue(ArgumentError) { |ex| @expected = 1 }.
+            rescue(LoadError) { |ex| @expected = 2 }.
+            rescue(StandardError) { |ex| @expected = 3 }
+        subject.post { raise ArgumentError }
+        sleep(0.1)
+        @expected.should eq 1
 
-          @expected = nil
-          subject.
-        rescue(ArgumentError) { |ex| @expected = 1 }.
-          rescue(LoadError) { |ex| @expected = 2 }.
-          rescue(StandardError) { |ex| @expected = 3 }
-            subject.post { raise LoadError }
-            sleep(0.1)
-            @expected.should eq 2
-
-            @expected = nil
-            subject.
-          rescue(ArgumentError) { |ex| @expected = 1 }.
+        @expected = nil
+        subject.
+            rescue(ArgumentError) { |ex| @expected = 1 }.
             rescue(LoadError) { |ex| @expected = 2 }.
             rescue(StandardError) { |ex| @expected = 3 }
-              subject.post { raise StandardError }
-              sleep(0.1)
-              @expected.should eq 3
-            end
+        subject.post { raise LoadError }
+        sleep(0.1)
+        @expected.should eq 2
+
+        @expected = nil
+        subject.
+            rescue(ArgumentError) { |ex| @expected = 1 }.
+            rescue(LoadError) { |ex| @expected = 2 }.
+            rescue(StandardError) { |ex| @expected = 3 }
+        subject.post { raise StandardError }
+        sleep(0.1)
+        @expected.should eq 3
+      end
 
       it 'passes the exception object to the matched block' do
         @expected = nil
         subject.
-      rescue(ArgumentError) { |ex| @expected = ex }.
-        rescue(LoadError) { |ex| @expected = ex }.
-        rescue(StandardError) { |ex| @expected = ex }
-          subject.post { raise StandardError }
-          sleep(0.1)
-          @expected.should be_a(StandardError)
-        end
+            rescue(ArgumentError) { |ex| @expected = ex }.
+            rescue(LoadError) { |ex| @expected = ex }.
+            rescue(StandardError) { |ex| @expected = ex }
+        subject.post { raise StandardError }
+        sleep(0.1)
+        @expected.should be_a(StandardError)
+      end
 
       it 'ignores rescuers without a block' do
         @expected = nil
         subject.
-      rescue(StandardError).
-        rescue(StandardError) { |ex| @expected = ex }
-          subject.post { raise StandardError }
-          sleep(0.1)
-          @expected.should be_a(StandardError)
-        end
+            rescue(StandardError).
+            rescue(StandardError) { |ex| @expected = ex }
+        subject.post { raise StandardError }
+        sleep(0.1)
+        @expected.should be_a(StandardError)
+      end
 
       it 'supresses the exception if no rescue matches' do
         lambda {
           subject.
-      rescue(ArgumentError) { |ex| @expected = ex }.
-        rescue(NotImplementedError) { |ex| @expected = ex }.
-        rescue(NoMethodError) { |ex| @expected = ex }
+              rescue(ArgumentError) { |ex| @expected = ex }.
+              rescue(NotImplementedError) { |ex| @expected = ex }.
+              rescue(NoMethodError) { |ex| @expected = ex }
           subject.post { raise StandardError }
           sleep(0.1)
         }.should_not raise_error
-        end
+      end
 
       it 'suppresses exceptions thrown from rescue handlers' do
         lambda {