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