lib/celluloid/mailbox/evented.rb in celluloid-0.17.2 vs lib/celluloid/mailbox/evented.rb in celluloid-0.17.3
- old
+ new
@@ -29,11 +29,11 @@
@mutex.unlock rescue nil
end
begin
current_actor = Thread.current[:celluloid_actor]
@reactor.wakeup unless current_actor && current_actor.mailbox == self
- rescue IOError
+ rescue
Internals::Logger.crash "reactor crashed", $ERROR_INFO
dead_letter(message)
end
nil
end
@@ -49,11 +49,9 @@
# after the given timeout:
@reactor.run_once(timeout)
# No message was received:
return nil
- rescue IOError
- raise MailboxShutdown, "mailbox shutdown called during receive"
end
# Obtain the next message from the mailbox that matches the given block
def next_message(block)
@mutex.lock