hala-net 0.1.2

Hala network 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

use std::io;

use futures::channel::mpsc::SendError;

#[derive(thiserror::Error, Debug)]
pub enum HalaIoError {
    #[error("{0}")]
    StdIoError(#[from] std::io::Error),

    #[error("{0}")]
    SendError(#[from] SendError),

    #[cfg(feature = "quice")]
    #[error("{0}")]
    QuicheError(#[from] quiche::Error),

    #[cfg(feature = "quice")]
    #[error("{0}")]
    Unspecified(#[from] ring::error::Unspecified),
}

impl From<HalaIoError> for std::io::Error {
    fn from(value: HalaIoError) -> Self {
        match value {
            HalaIoError::SendError(send_error) => {
                std::io::Error::new(std::io::ErrorKind::BrokenPipe, send_error)
            }
            HalaIoError::StdIoError(io_error) => io_error,
            #[cfg(feature = "quice")]
            HalaIoError::QuicheError(err) => match err {
                quiche::Error::StreamStopped(_) | quiche::Error::InvalidStreamState(_) => {
                    std::io::Error::new(std::io::ErrorKind::BrokenPipe, err)
                }
                _ => std::io::Error::new(std::io::ErrorKind::Other, err),
            },
            #[cfg(feature = "quice")]
            HalaIoError::Unspecified(err) => std::io::Error::new(std::io::ErrorKind::Other, err),
        }
    }
}

pub fn into_io_error<E: Into<HalaIoError>>(error: E) -> io::Error {
    let err: HalaIoError = error.into();

    err.into()
}