Hemera/tytix
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add more ergonomic constructor of ActorHandles

Browse source 
Signed-off-by: Marcel Müller <neikos@neikos.email>
This commit is contained in:
Marcel Müller 2025-11-05 14:48:51 +01:00
parent d38b04396c
commit 023a2a17fc
1 changed files with 20 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

32
crates/tytix-core/src/actor.rs
View file

@ -7,10 +7,23 @@ use crate::IsContainedInBundle;
use crate::Message;
use crate::MessageBundle;
pub trait Actor: Any {
pub trait Actor: Any
where
Self: ActorHandler<Self::HandledMessages>,
{
type HandledMessages: MessageBundle;
}
pub trait IntoActorHandle<MB> {
fn into_actor_handle(self) -> ActorHandle<MB>;
}
impl<A: Actor> IntoActorHandle<A::HandledMessages> for A {
fn into_actor_handle(self) -> ActorHandle<A::HandledMessages> {
ActorHandle::new(self)
}
}
pub trait Handle<M: Message> {
fn handle(&mut self, message: M) -> impl Future<Output = anyhow::Result<M::Reply>>;
}
@ -26,7 +39,7 @@ macro_rules! impl_actor_handle {
( $($ty:ident),* ) => {
impl<ACTOR, $($ty,)*> ActorHandler<($($ty,)*)> for ACTOR
where
ACTOR: Actor<HandledMessages = ($($ty,)*)>,
ACTOR: Actor,
$( ACTOR: Handle<$ty>, )*
$( $ty: Message, )*
{
@ -40,7 +53,7 @@ macro_rules! impl_actor_handle {
$(
let msg = match msg.into_inner::<$ty>() {
Ok(msg) => {
return self.handle(msg).await.map(InternalMessage::new);
return <Self as Handle<$ty>>::handle(self, msg).await.map(InternalMessage::new);
}
Err(msg) => msg,
};
@ -50,6 +63,7 @@ macro_rules! impl_actor_handle {
}
}
}
};
}
@ -112,12 +126,6 @@ mod tests {
type Reply = ();
}
struct Zap;
impl Message for Zap {
type Reply = ();
}
struct FActor;
impl Actor for FActor {
@ -126,14 +134,14 @@ mod tests {
impl Handle<Foo> for FActor {
async fn handle(&mut self, _message: Foo) -> anyhow::Result<<Foo as Message>::Reply> {
todo!()
Ok(())
}
}
#[apply(test!)]
async fn test_name() {
let mut actor = ActorHandle::new(FActor);
let mut actor = FActor.into_actor_handle();
actor.handle(Zap).await.unwrap();
actor.handle(Foo).await.unwrap();
}
}