Allow TaskThread to raise exceptions outside

lib/celluloid/tasks/task_thread.rb

@@ -8,6 +8,7 @@ def initialize(type)
       super
 
       @resume_queue = Queue.new
+      @exception_queue = Queue.new
       @yield_mutex  = Mutex.new
       @yield_cond   = ConditionVariable.new
 
@@ -32,6 +33,8 @@ def initialize(type)
           yield
         rescue Task::TerminatedError
           # Task was explicitly terminated
+        rescue Exception => ex
+          @exception_queue << ex
         ensure
           @status = :dead
           actor.tasks.delete self
@@ -59,6 +62,9 @@ def resume(value = nil)
       @yield_mutex.synchronize do
         @resume_queue.push(value)
         @yield_cond.wait(@yield_mutex)
+        while @exception_queue.size > 0
+          raise @exception_queue.pop
+        end
       end
 
       nil

spec/support/task_examples.rb

@@ -33,4 +33,13 @@ def initialize
     subject.should_not be_running
   end
 
+  it "raises exceptions outside" do
+    task = task_class.new(task_type) do
+      raise "failure"
+    end
+    expect do
+      task.resume
+    end.to raise_exception("failure")
+  end
+
 end