ActorContext#post now supresses exceptions thrown in the callback block.

Author: jdantonio

lib/concurrent/simple_actor_ref.rb

@@ -99,7 +99,13 @@ def run_message_loop
         ensure
           now = Time.now
           message.ivar.complete(ex.nil?, result, ex)
-          message.callback.call(now, result, ex) if message.callback
+
+          begin
+            message.callback.call(now, result, ex) if message.callback
+          rescue @exception_class => ex
+            # suppress
+          end
+
           observers.notify_observers(now, message.payload, result, ex)
         end
       end

spec/concurrent/actor_ref_shared.rb

@@ -115,6 +115,17 @@ def receive(*msg)
       expected_value.should be_nil
       expected_reason.should be_a StandardError
     end
+
+    it 'supresses exceptions thrown by the callback' do
+      expected = nil
+      subject.post(:foo){|time, value, reason| raise StandardError }
+      sleep(0.1)
+
+      subject.post(:bar){|time, value, reason| expected = value }
+      sleep(0.1)
+
+      expected.should eq :bar
+    end
   end
 
   context '#post!' do