Log actor panics in StopSupervisor

src/future.rs

@@ -14,6 +14,7 @@ use log::error;
 
 use crate::actor::{self, Actor, NewActor};
 use crate::actor_ref::ActorRef;
+use crate::panic_message;
 use crate::supervisor::{Supervisor, SupervisorStrategy};
 
 /// A [`Future`] that represent an [`Actor`].
@@ -197,18 +198,6 @@ where
     }
 }
 
-/// Attempts to extract a message from a panic, defaulting to `<unknown>`.
-/// NOTE: be sure to derefence the `Box`!
-fn panic_message<'a>(panic: &'a (dyn Any + Send + 'static)) -> &'a str {
-    match panic.downcast_ref::<&'static str>() {
-        Some(s) => s,
-        None => match panic.downcast_ref::<String>() {
-            Some(s) => s,
-            None => "<unknown>",
-        },
-    }
-}
-
 /// Called when we can't create a new receiver for the sync actor.
 #[cold]
 fn inbox_failure<T>(_: ReceiverConnected) -> T {

src/lib.rs

@@ -96,3 +96,15 @@ pub use future::{ActorFuture, ActorFutureBuilder};
 pub use supervisor::{Supervisor, SupervisorStrategy, SyncSupervisor};
 #[doc(no_inline)]
 pub use sync::{SyncActor, SyncActorRunner, SyncActorRunnerBuilder};
+
+/// Attempts to extract a message from a panic, defaulting to `<unknown>`.
+/// NOTE: be sure to derefence the `Box`!
+fn panic_message<'a>(panic: &'a (dyn std::any::Any + Send + 'static)) -> &'a str {
+    match panic.downcast_ref::<&'static str>() {
+        Some(s) => s,
+        None => match panic.downcast_ref::<String>() {
+            Some(s) => s,
+            None => "<unknown>",
+        },
+    }
+}

src/supervisor.rs

@@ -97,7 +97,7 @@ use std::fmt;
 
 use log::warn;
 
-use crate::{Actor, NewActor, SyncActor};
+use crate::{panic_message, Actor, NewActor, SyncActor};
 
 /// The supervisor of an [actor].
 ///
@@ -387,6 +387,15 @@ where
             self.0
         );
     }
+
+    fn decide_on_panic(
+        &mut self,
+        panic: Box<dyn Any + Send + 'static>,
+    ) -> SupervisorStrategy<NA::Argument> {
+        let msg = panic_message(&*panic);
+        warn!("{} panicked, stopping it: {msg}", self.0);
+        SupervisorStrategy::Stop
+    }
 }
 
 impl<A> SyncSupervisor<A> for StopSupervisor
@@ -398,6 +407,15 @@ where
         warn!("{} failed, stopping it: {err}", self.0);
         SupervisorStrategy::Stop
     }
+
+    fn decide_on_panic(
+        &mut self,
+        panic: Box<dyn Any + Send + 'static>,
+    ) -> SupervisorStrategy<A::Argument> {
+        let msg = panic_message(&*panic);
+        warn!("{} panicked, stopping it: {msg}", self.0);
+        SupervisorStrategy::Stop
+    }
 }
 
 /// Macro to create a supervisor that logs the error and restarts the actor.