#actor #futures #async #xactor #async-std

xactor

Xactor is a rust actors framework based on async-std

32 releases

0.7.11 Dec 29, 2020
0.7.8 Sep 28, 2020
0.7.6 Jul 8, 2020
0.6.4 Mar 18, 2020

#14 in #actor-model

Download history 50/week @ 2022-11-29 118/week @ 2022-12-06 62/week @ 2022-12-13 98/week @ 2022-12-20 109/week @ 2022-12-27 42/week @ 2023-01-03 78/week @ 2023-01-10 43/week @ 2023-01-17 142/week @ 2023-01-24 171/week @ 2023-01-31 61/week @ 2023-02-07 175/week @ 2023-02-14 175/week @ 2023-02-21 57/week @ 2023-02-28 101/week @ 2023-03-07 88/week @ 2023-03-14

468 downloads per month
Used in 2 crates

MIT license

42KB
740 lines

Xactor is a rust actors framework based on async-std

Documentation

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

References

Dependencies

~1.5–7.5MB
~127K SLoC