refactor: Modify actor receive function parameters

examples/actor-hello-world/main.rs

@@ -4,7 +4,7 @@ use nexus_acto_rs::actor::actor::actor_error::ActorError;
 use nexus_acto_rs::actor::actor::props::Props;
 use nexus_acto_rs::actor::actor_system::ActorSystem;
 use nexus_acto_rs::actor::context::context_handle::ContextHandle;
-use nexus_acto_rs::actor::context::{SenderPart, SpawnerPart};
+use nexus_acto_rs::actor::context::{MessagePart, SenderPart, SpawnerPart};
 use nexus_acto_rs::actor::message::message::Message;
 use nexus_acto_rs::actor::message::message_handle::MessageHandle;
 use std::any::Any;
@@ -31,7 +31,8 @@ struct HelloActor;
 
 #[async_trait]
 impl Actor for HelloActor {
-  async fn receive(&mut self, _: ContextHandle, message_handle: MessageHandle) -> Result<(), ActorError> {
+  async fn receive(&mut self, ctx: ContextHandle) -> Result<(), ActorError> {
+    let message_handle = ctx.get_message_handle().await;
     let hello = message_handle.to_typed::<Hello>().unwrap();
     println!("Hello, {}!", hello.who);
     Ok(())

examples/actor-supervision/main.rs

@@ -29,11 +29,8 @@ impl Parent {
 
 #[async_trait]
 impl Actor for Parent {
-  async fn receive(
-    &mut self,
-    mut context_handle: ContextHandle,
-    message_handle: MessageHandle,
-  ) -> Result<(), ActorError> {
+  async fn receive(&mut self, mut context_handle: ContextHandle) -> Result<(), ActorError> {
+    let message_handle = context_handle.get_message_handle().await;
     let msg = message_handle.to_typed::<Hello>().unwrap();
     let props = Props::from_actor_producer(|_| async { Child::new() }).await;
     let child = context_handle.spawn(props).await;

src/actor/actor/actor.rs

@@ -3,12 +3,9 @@ use std::fmt::Debug;
 use async_trait::async_trait;
 
 use crate::actor::actor::actor_error::ActorError;
-use crate::actor::actor::actor_inner_error::ActorInnerError;
 use crate::actor::context::context_handle::ContextHandle;
 use crate::actor::context::MessagePart;
 use crate::actor::message::auto_receive_message::AutoReceiveMessage;
-use crate::actor::message::message_handle::MessageHandle;
-use crate::actor::message::message_or_envelope::{unwrap_envelope_message, MessageEnvelope};
 use crate::actor::message::terminate_info::TerminateInfo;
 use crate::actor::supervisor::supervisor_strategy_handle::SupervisorStrategyHandle;
 

src/actor/actor/actor_handle.rs

@@ -6,7 +6,6 @@ use tokio::sync::Mutex;
 use crate::actor::actor::actor::Actor;
 use crate::actor::actor::actor_error::ActorError;
 use crate::actor::context::context_handle::ContextHandle;
-use crate::actor::message::message_handle::MessageHandle;
 use crate::actor::supervisor::supervisor_strategy_handle::SupervisorStrategyHandle;
 
 #[derive(Debug, Clone)]

src/actor/actor/behavior_test.rs

@@ -3,10 +3,9 @@ mod tests {
   use crate::actor::actor::actor::Actor;
   use crate::actor::actor::actor_error::ActorError;
   use crate::actor::actor::behavior::Behavior;
-  use crate::actor::actor::props::Props;
-  use crate::actor::actor_system::ActorSystem;
+
   use crate::actor::context::context_handle::ContextHandle;
-  use crate::actor::context::{BasePart, MessagePart, SenderPart, SpawnerPart};
+  use crate::actor::context::{BasePart, MessagePart};
   use crate::actor::message::message::Message;
   use crate::actor::message::response::ResponseHandle;
   use async_trait::async_trait;

src/main.rs

@@ -40,7 +40,8 @@ impl Actor for ChildActor {
     Ok(())
   }
 
-  async fn receive(&mut self, _: ContextHandle, message_handle: MessageHandle) -> Result<(), ActorError> {
+  async fn receive(&mut self, ctx: ContextHandle) -> Result<(), ActorError> {
+    let message_handle = ctx.get_message_handle().await;
     tracing::debug!("ChildActor::receive: msg = {:?}", message_handle);
     Ok(())
   }