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

use std::fmt::Debug;
use std::sync::Arc;

use async_trait::async_trait;

use crate::actor::message::message_handle::MessageHandle;

// MailboxMiddleware trait
#[async_trait]
pub trait MailboxMiddleware: Debug + Send + Sync {
  async fn mailbox_started(&self);
  async fn message_posted(&self, message_handle: MessageHandle);
  async fn message_received(&self, message_handle: MessageHandle);
  async fn mailbox_empty(&self);
}

#[derive(Debug, Clone)]
pub struct MailboxMiddlewareHandle(Arc<dyn MailboxMiddleware>);

impl PartialEq for MailboxMiddlewareHandle {
  fn eq(&self, other: &Self) -> bool {
    Arc::ptr_eq(&self.0, &other.0)
  }
}

impl Eq for MailboxMiddlewareHandle {}

impl std::hash::Hash for MailboxMiddlewareHandle {
  fn hash<H: std::hash::Hasher>(&self, state: &mut H) {
    (self.0.as_ref() as *const dyn MailboxMiddleware).hash(state);
  }
}

impl MailboxMiddlewareHandle {
  pub fn new(middleware: impl MailboxMiddleware + 'static) -> Self {
    MailboxMiddlewareHandle(Arc::new(middleware))
  }
}

#[async_trait]
impl MailboxMiddleware for MailboxMiddlewareHandle {
  async fn mailbox_started(&self) {
    self.0.mailbox_started().await;
  }

  async fn message_posted(&self, message_handle: MessageHandle) {
    self.0.message_posted(message_handle).await;
  }

  async fn message_received(&self, message_handle: MessageHandle) {
    self.0.message_received(message_handle).await;
  }

  async fn mailbox_empty(&self) {
    self.0.mailbox_empty().await;
  }
}