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

use std::any::Any;

use crate::actor::message::message::Message;
use crate::actor::message::terminate_info::TerminateInfo;
use crate::actor::message::watch::{Unwatch, Watch};

#[derive(Debug, Clone)]
pub enum SystemMessage {
  Restart,
  Start,
  Stop,
  Watch(Watch),
  Unwatch(Unwatch),
  Terminate(TerminateInfo),
}

impl Message for SystemMessage {
  fn eq_message(&self, other: &dyn Message) -> bool {
    let msg = other.as_any().downcast_ref::<SystemMessage>();
    match (self, msg) {
      (SystemMessage::Restart, Some(&SystemMessage::Restart)) => true,
      (SystemMessage::Start, Some(&SystemMessage::Start)) => true,
      (SystemMessage::Stop, Some(&SystemMessage::Stop)) => true,
      (SystemMessage::Watch(_), Some(&SystemMessage::Watch(_))) => true,
      (SystemMessage::Unwatch(_), Some(&SystemMessage::Unwatch(_))) => true,
      (SystemMessage::Terminate(me), Some(&SystemMessage::Terminate(ref you))) => *me == *you,
      _ => false,
    }
  }

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

impl SystemMessage {
  fn as_any(&self) -> &dyn Any {
    self
  }

  fn system_message(&self) {}
}