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 {}
#[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(())
}

Performance

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

Installation

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-tokio

You can edit your

Cargo.toml

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

References

• Actix
• Async-std
• Tokio