ascolt 0.1.11

Async runtime-agnostic 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
69
70
71
72
73
74
75
76
77

use async_channel::RecvError;
use derive_more::From;
use std::fmt::{self, Debug};
use thiserror::Error;

#[doc(hidden)]
#[derive(Error, Debug, From)]
pub enum ActorRuntimeError {
    #[error("Init error: {0}")]
    Init(ActorInitFailure),
    #[error("Receive message error: {0}")]
    Receive(RecvError),
    #[error("Stop hook error: {0}")]
    Stop(ActorStopFailure),
    #[error("Error while processing handler error: {0}")]
    HandleError(ActorHandleErrorFailure),
}

#[derive(Error, Debug)]
#[error("Actor init error: {0}")]
struct ActorInitFailureContainer(#[source] Box<dyn std::error::Error + Send + Sync>);
#[derive(Debug)]
pub struct ActorInitFailure(ActorInitFailureContainer);
impl<E> From<E> for ActorInitFailure
where
    E: std::error::Error + Send + Sync + 'static,
{
    fn from(value: E) -> Self {
        let container = ActorInitFailureContainer(Box::new(value));
        ActorInitFailure(container)
    }
}
impl fmt::Display for ActorInitFailure {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "{}", self.0)
    }
}

#[derive(Error, Debug)]
#[error("Actor stop error: {0}")]
struct ActorStopFailureContainer(#[source] Box<dyn std::error::Error + Send + Sync>);
#[derive(Debug)]
pub struct ActorStopFailure(ActorStopFailureContainer);
impl<E> From<E> for ActorStopFailure
where
    E: std::error::Error + Send + Sync + 'static,
{
    fn from(value: E) -> Self {
        let container = ActorStopFailureContainer(Box::new(value));
        ActorStopFailure(container)
    }
}
impl fmt::Display for ActorStopFailure {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "{}", self.0)
    }
}

#[derive(Error, Debug)]
#[error("Actor handle error error: {0}")]
struct ActorHandleErrorFailureContainer(#[source] Box<dyn std::error::Error + Send + Sync>);
#[derive(Debug)]
pub struct ActorHandleErrorFailure(ActorHandleErrorFailureContainer);
impl<E> From<E> for ActorHandleErrorFailure
where
    E: std::error::Error + Send + Sync + 'static,
{
    fn from(value: E) -> Self {
        let container = ActorHandleErrorFailureContainer(Box::new(value));
        ActorHandleErrorFailure(container)
    }
}
impl fmt::Display for ActorHandleErrorFailure {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        write!(f, "{}", self.0)
    }
}