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

#[cfg(test)]
mod test {
  use std::any::Any;
  use std::env;
  use std::time::Duration;

  use tracing_subscriber::EnvFilter;

  use crate::actor::actor::props::Props;
  use crate::actor::actor_system::ActorSystem;
  use crate::actor::context::{BasePart, MessagePart, SenderPart, SpawnerPart};
  use crate::actor::message::message::Message;
  use crate::actor::message::message_handle::MessageHandle;
  use crate::actor::message::readonly_message_headers::ReadonlyMessageHeaders;
  use crate::actor::message::response::ResponseHandle;

  #[derive(Debug)]
  pub struct Length(pub usize);

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

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

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

    let system = ActorSystem::new().await;

    let props = Props::from_actor_receiver(move |ctx| async move {
      let msg = ctx.get_message_envelope_opt().await;
      if msg.is_some() {
        let l = ctx
          .get_message_header_handle()
          .await
          .map(|v| v.keys().len())
          .unwrap_or(0);
        ctx.respond(ResponseHandle::new(Length(l))).await
      }
      Ok(())
    })
    .await;

    let mut root_context = system.get_root_context().await;
    let pid = root_context.spawn(props).await;

    let d = Duration::from_secs(1);

    let f = root_context
      .request_future(pid, MessageHandle::new("Hello".to_string()), d)
      .await;

    let _ = f.result().await.unwrap();
  }
}