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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

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

  use async_trait::async_trait;
  use tokio::time::sleep;
  use tracing_subscriber::EnvFilter;

  use crate::actor::actor::actor::Actor;
  use crate::actor::actor::actor_error::ActorError;
  use crate::actor::actor::props::Props;
  use crate::actor::actor_system::{ActorSystem, Config, ConfigOption};
  use crate::actor::context::context_handle::ContextHandle;
  use crate::actor::context::{InfoPart, SenderPart, SpawnerPart};
  use crate::actor::message::message::Message;
  use crate::actor::message::message_handle::MessageHandle;
  use crate::actor::supervisor::supervisor_strategy_handle::SupervisorStrategyHandle;

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

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

    let system = ActorSystem::new_config_options([ConfigOption::SetLogLevel(LogLevel::Debug)]).await;
    let root = system.get_root_context().await;
    assert_eq!(root.get_self_opt().await, None);

    sleep(std::time::Duration::from_secs(1)).await;
  }

  #[tokio::test]
  async fn test_actor_system_new_with_config() {
    let system = ActorSystem::new_with_config(Config::default()).await;
    let root = system.get_root_context().await;
    assert_eq!(root.get_self_opt().await, None);
  }

  #[derive(Debug, Clone)]
  struct Hello(pub String);

  impl Message for Hello {
    fn eq_message(&self, other: &dyn Message) -> bool {
      self.0 == other.as_any().downcast_ref::<Hello>().unwrap().0
    }

    fn as_any(&self) -> &(dyn std::any::Any + Send + Sync + 'static) {
      self
    }
  }

  #[derive(Debug)]
  struct MyActor {
    b: AsyncBarrier,
  }

  #[async_trait]
  impl Actor for MyActor {
    async fn receive(&mut self, _: ContextHandle) -> Result<(), ActorError> {
      self.b.wait().await;
      Ok(())
    }

    async fn get_supervisor_strategy(&self) -> Option<SupervisorStrategyHandle> {
      None
    }
  }

  #[tokio::test]
  async fn test_actor_system_spawn_actor() {
    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 cloned_b = b.clone();
    let system = ActorSystem::new().await;
    let mut root_context = system.get_root_context().await;

    let props = Props::from_actor_producer(move |_| {
      let cloned_b = b.clone();
      async move { MyActor { b: cloned_b.clone() } }
    })
    .await;

    let pid = root_context.spawn(props).await;
    root_context
      .send(pid, MessageHandle::new(Hello("hello".to_string())))
      .await;

    cloned_b.wait().await;
  }
}