lib/celluloid/task/threaded.rb in celluloid-0.17.0 vs lib/celluloid/task/threaded.rb in celluloid-0.17.1
- old
+ new
@@ -16,13 +16,13 @@
def create
# TODO: move this to ActorSystem#get_thread (ThreadHandle inside Group::Pool)
thread = Internals::ThreadHandle.new(Thread.current[:celluloid_actor_system], :task) do
begin
ex = @resume_queue.pop
- fail ex if ex.is_a?(Task::TerminatedError)
+ fail ex if ex.is_a?(TaskTerminated)
yield
- rescue Exception => ex
+ rescue ::Exception => ex
@exception_queue << ex
ensure
@yield_mutex.synchronize do
@yield_cond.signal
end