Xactor is a rust actors framework based on async-std

Documentation

GitHub repository
Cargo package
Minimum supported Rust version: 1.39 or later

Features

Async actors.
Actor communication in a local context.
Using Futures for asynchronous message handling.
Typed messages (No Any type). Generic messages are allowed.

Examples

use xactor::*;
#[message(result = "String")] struct ToUppercase(String);
struct MyActor;
impl Actor for MyActor {}
#[asynctrait::asynctrait] impl Handler<ToUppercase> for MyActor {     async fn handle(&mut self, _ctx: &mut Context<Self>, 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(()) }

Performance

https://github.com/sunli829/xactor-benchmarks

Installation

Xactor requires async-trait on userland.

With [cargo add][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-tokio and disable default features.

You can edit your Cargo.toml as follows:

xactor = { version = "x.x.x", features = ["runtime-tokio"], default-features = false }

[cargo-add]: https://github.com/killercup/cargo-edit

References

🔗 More in this category