Merge pull request #533 from faucct/master

Concurrent::Atom#swap fixed: reraise the exceptions from block

Author: jdantonio

lib/concurrent/atom.rb

@@ -158,8 +158,8 @@ def swap(*args)
 
       loop do
         old_value = value
+        new_value = yield(old_value, *args)
         begin
-          new_value = yield(old_value, *args)
           break old_value unless valid?(new_value)
           break new_value if compare_and_set(old_value, new_value)
         rescue

spec/concurrent/atom_spec.rb

@@ -151,6 +151,15 @@ module Concurrent
 
         expect(counter.value).to be > 1
       end
+
+      it 'reraises the exception from block' do
+        atom = Atom.new(0)
+        expect do
+          atom.swap do |value|
+            fail 'something went wrong'
+          end
+        end.to raise_error 'something went wrong'
+      end
     end
 
     context '#reset' do