yaaf 0.2.0

Yet Another Actor Framework
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
58
59
60
61
62
63
64
65
66
67
68

use ::thiserror::Error;
use ::tokio::sync::{mpsc::error::SendError, oneshot::error::RecvError};

#[derive(Debug, Error)]
pub enum YaafError {
    #[error(transparent)]
    AddressError(#[from] AddressError),
    #[error(transparent)]
    ContextError(#[from] ContextError),
    #[error(transparent)]
    SystemError(#[from] SystemError),
}

#[derive(Debug, Error)]
pub enum AddressError {
    #[error("failed to find router")]
    RouterLookupError,
    #[error("failed to tell actor")]
    TellFailure { source: YaafInternalError },
}

#[derive(Debug, Error)]
pub enum ContextError {
    #[error("failed to find router")]
    RouterLookupError,
    #[error("failed to broadcast message")]
    BroadcastFailure { source: YaafInternalError },
}

#[derive(Debug, Error)]
pub enum SystemError {
    #[error("failed to add actor")]
    AddActorFailure { source: YaafInternalError },
    #[error("failed to add source")]
    AddSourceFailure { source: YaafInternalError },
    #[error("failed to create system")]
    CreateError { source: YaafInternalError },
    #[error("failed to add actor")]
    ShutdownError { source: YaafInternalError },
}

#[derive(Debug, Error)]
pub enum YaafInternalError {
    #[error("failed to create router")]
    CreateRouterFailure { source: Box<YaafInternalError> },
    #[error("failed to subscribe to messages")]
    MailboxSubscribeFailure { source: Box<YaafInternalError> },
    #[error("failed to subscribe to system events")]
    MailboxSystemSubscribeFailure { source: Box<YaafInternalError> },
    #[error("failed to receive subscription confirmation")]
    ReceiveFailure,
    #[error("failed to lookup router")]
    RouterLookupFailure,
    #[error("failed to send")]
    SendFailure,
}

impl<T> From<SendError<T>> for YaafInternalError {
    fn from(_src: SendError<T>) -> Self {
        YaafInternalError::SendFailure
    }
}

impl From<RecvError> for YaafInternalError {
    fn from(_src: RecvError) -> Self {
        YaafInternalError::ReceiveFailure
    }
}