polybox-core 0.0.2

Message-passing abstractions to make working with channels and actors a more seamless experience
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

use crate::RxError;
use thiserror::Error;

/// Error returned when sending a message, checking at compile-time that
/// the message is actually accepted by the actor.
#[derive(Debug, thiserror::Error, Clone, PartialEq, Eq, Hash)]
pub enum SendCheckedError<M> {
    Closed(M),
    NotAccepted(M),
}

/// The channel has been closed, and no longer accepts new messages.
#[derive(Debug, Clone, PartialEq, Eq, Hash, Error)]
pub struct SendError<M>(pub M);

/// Error returned when sending a request.
///
/// This error combines failures in sending and receiving.
#[derive(Debug, thiserror::Error, Clone, Copy, PartialEq, Eq)]
pub enum RequestError<M> {
    NoReply,
    Closed(M),
}

impl<T> From<SendError<T>> for SendCheckedError<T> {
    fn from(err: SendError<T>) -> Self {
        Self::Closed(err.0)
    }
}

impl<T> From<RxError> for RequestError<T> {
    fn from(RxError: RxError) -> Self {
        Self::NoReply
    }
}

impl<T> From<SendError<T>> for RequestError<T> {
    fn from(err: SendError<T>) -> Self {
        Self::Closed(err.0)
    }
}