nexus-acto-rs 0.4.2

A Rust crate for Actors
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

#![cfg(test)]
mod tests {
  use std::env;

  use tracing_subscriber::EnvFilter;

  use crate::actor::actor::props::Props;
  use crate::actor::actor_system::ActorSystem;
  use crate::actor::context::{MessagePart, SpawnerPart};
  use crate::actor::message::auto_receive_message::AutoReceiveMessage;
  use crate::actor::message::message::Message;

  use crate::actor::util::async_barrier::AsyncBarrier;

  #[tokio::test]
  async fn example_root_context_spawn_named() {
    let _ = env::set_var("RUST_LOG", "debug");
    let _ = tracing_subscriber::fmt()
      .with_env_filter(EnvFilter::from_default_env())
      .try_init();

    let b = AsyncBarrier::new(2);

    let system = ActorSystem::new().await;
    let cloned_b = b.clone();

    let props = Props::from_actor_receiver(move |ctx| {
      let cloned_b = cloned_b.clone();
      async move {
        let msg = ctx.get_message_handle_opt().await.unwrap();
        if let Some(AutoReceiveMessage::PostStart) = msg.as_any().downcast_ref::<AutoReceiveMessage>() {
          tracing::debug!("Hello World!");
          cloned_b.wait().await;
        }
        Ok(())
      }
    })
    .await;

    if let Err(err) = system.get_root_context().await.spawn_named(props, "my-actor").await {
      panic!("Failed to spawn actor: {:?}", err);
    }

    b.wait().await;
  }
}