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

use std::any::Any;
use std::fmt::Debug;

use crate::util::queue::priority_queue::DEFAULT_PRIORITY;

pub trait Message: Debug + Send + Sync + 'static {
  fn get_priority(&self) -> i8 {
    DEFAULT_PRIORITY
  }
  fn eq_message(&self, other: &dyn Message) -> bool;
  fn as_any(&self) -> &(dyn Any + Send + Sync + 'static);
}

impl<T: prost::Message + PartialEq + 'static> Message for T {
  fn eq_message(&self, other: &dyn Message) -> bool {
    match (self.as_any().downcast_ref::<T>(), other.as_any().downcast_ref::<T>()) {
      (Some(self_msg), Some(other_msg)) => self_msg == other_msg,
      _ => false,
    }
  }

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