mm1-core 0.7.23

An Erlang-style actor runtime for Rust.
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

use std::fmt;

use mm1_address::address::Address;
use mm1_address::subnet::NetAddress;

use crate::envelope::Envelope;

pub struct OnSend<'a> {
    pub sent_by_addr: Address,
    pub sent_by_net:  NetAddress,
    pub sent_by_key:  &'a dyn fmt::Display,
    pub sent_to_addr: Address,
    pub envelope:     &'a Envelope,
}

pub struct OnRecv<'a> {
    pub recv_by_addr: Address,
    pub recv_by_net:  NetAddress,
    pub recv_by_key:  &'a dyn fmt::Display,
    pub envelope:     &'a Envelope,
}

pub trait MessageTap: fmt::Debug + Send + Sync + 'static {
    fn on_send(&self, event: OnSend<'_>);
    fn on_recv(&self, event: OnRecv<'_>);
}

#[derive(Debug)]
pub struct NoopTap;

impl MessageTap for NoopTap {
    fn on_send(&self, _event: OnSend<'_>) {}

    fn on_recv(&self, _event: OnRecv<'_>) {}
}