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

use std::time::Duration;

use mm1_address::address::Address;
use mm1_common::errors::error_of::ErrorOf;
use mm1_common::impl_error_kind;
use mm1_proto::message;

pub trait Ping: Send {
    // fn set_trap_ping(&mut self, enable: bool) -> impl Future<Output = ()>;
    fn ping(
        &mut self,
        address: Address,
        timeout: Duration,
    ) -> impl Future<Output = Result<Duration, ErrorOf<PingErrorKind>>> + Send;
}

#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash)]
#[message(base_path = ::mm1_proto)]
pub enum PingErrorKind {
    Timeout,
    Send,
    Recv,
}

impl_error_kind!(PingErrorKind);