Concurrent::Edge::AbstractPromise now rescues Exception

Author: David Abdemoulaie

lib/concurrent/edge/future.rb

@@ -925,8 +925,11 @@ def complete_with(new_state, raise_on_reassign = true)
       # @return [Future]
       def evaluate_to(*args, block)
         complete_with Future::Success.new(block.call(*args))
-      rescue => error
+      rescue StandardError => error
         complete_with Future::Failed.new(error)
+      rescue Exception => error
+        complete_with Future::Failed.new(error)
+        raise error
       end
     end
 

spec/concurrent/edge/future_spec.rb

@@ -334,6 +334,14 @@
         expect(f.reason).to be_an_instance_of TypeError
       end
     end
+
+    it 'completes future when Exception raised' do
+      f = Concurrent.future { raise Exception, 'fail' }
+      sleep 0.2
+      expect(f).to be_completed
+      expect(f).to be_failed
+      expect{ f.value! }.to raise_error(Exception, 'fail')
+    end
   end
 
   describe 'interoperability' do