pirates 0.1.2

Simple async RPC lib
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

use crate::transport::TransportError;
use std::error::Error;
use std::fmt::{Display, Formatter};

#[derive(Debug)]
pub enum RpcError {
    ParseError(serde_pickle::error::Error),
    TransportError(TransportError),
    Custom(String),
}

impl Display for RpcError {
    fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::ParseError(pickle) => write!(f, "{}", pickle),
            Self::TransportError(transport_error) => write!(f, "{}", transport_error),
            Self::Custom(s) => write!(f, "{}", s),
        }
    }
}

impl Error for RpcError {}

impl From<serde_pickle::Error> for RpcError {
    fn from(e: serde_pickle::Error) -> Self {
        Self::ParseError(e)
    }
}
impl From<TransportError> for RpcError {
    fn from(e: TransportError) -> Self {
        Self::TransportError(e)
    }
}

// TODO: Make this an actual struct and not just a type alias
pub type RpcResult<A> = Result<A, RpcError>;

pub fn into_rpc_result_transport<T>(result: Result<T, TransportError>) -> RpcResult<T> {
    match result {
        Ok(bytes) => Ok(bytes),
        Err(e) => Err(RpcError::TransportError(e)),
    }
}