Xactor is a rust actors framework based on async-std
Anytype). Generic messages are allowed.
use xactor::*;#[message(result = "String")] struct ToUppercase(String);
struct MyActor;
impl Actor for MyActor {}
#[async_trait::async_trait] impl Handler for MyActor { async fn handle(&mut self, _ctx: &mut Context, msg: ToUppercase) -> String { msg.0.to_uppercase() } }
#[xactor::main] async fn main() -> Result { // Start actor and get its address let mut addr = MyActor.start().await?;
// Send message `ToUppercase` to actor via addr let res = addr.call(ToUppercase("lowercase".to_string())).await?; assert_eq!(res, "LOWERCASE"); Ok(())
}
https://github.com/sunli829/xactor-benchmarks
Xactor requires async-trait on userland.
With cargo add installed, run:
$ cargo add xactor $ cargo add async-trait
We also provide the tokio runtime instead of async-std. To use it, you need to activate
runtime-tokioand disable default features.
You can edit your
Cargo.tomlas follows:
toml xactor = { version = "x.x.x", features = ["runtime-tokio"], default-features = false }