monoio-netreq 0.1.2

monoio-netreq is a user-friendly HTTP client library designed for use with the Monoio runtime
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

use http::Error as HttpError;
use http::header::InvalidHeaderValue;
use monoio_transports::{FromUriError, TransportError as MonoioTransportError};
#[cfg(not(feature = "hyper-tls"))]
use monoio_http::common::error::HttpError as MonoioHttpError;
#[cfg(any(feature = "hyper", feature = "pool-hyper", feature = "hyper-tls"))]
use monoio_transports::{
    connectors::pollio::PollConnectError,
    http::hyper::HyperError
};
#[cfg(feature = "hyper-tls")]
use monoio_transports::http::hyper::TlsError;
use serde_json::Error as SerdeError;
use thiserror::{Error as ThisError, Error};

#[cfg(not(feature = "hyper-tls"))]
pub type Result<T> = std::result::Result<T, Error>;

#[derive(ThisError, Debug)]
pub enum Error {
    #[error("{0:?}")]
    InvalidHeaderValue(InvalidHeaderValue),
    #[error("error building http request: {0:?}")]
    HttpRequestBuilder(HttpError),
    #[error("http request version and http protocol does not match: {0:?}")]
    HttpVersionMismatch(String),
    #[error("error making pool key from uri: {0:?}")]
    UriKeyError(FromUriError),
    #[error("{0:?}")]
    TransportError(TransportError),
    #[cfg(not(feature = "hyper-tls"))]
    #[error("{0:?}")]
    HttpResponseError(MonoioHttpError),
    #[cfg(any(feature = "hyper", feature = "pool-hyper", feature = "hyper-tls"))]
    #[error("{0:?}")]
    HyperResponseError(hyper::Error),
    #[error("{0:?}")]
    BytesError(String),
    #[error("serde body deserialize error: {0:?}")]
    SerdeDeserializeError(SerdeError),
    #[error("Hyper Connector was not initialized")]
    ConnectorNotInitialized,
}

#[derive(Debug, Error)]
pub enum TransportError {
    #[error("http connector error: {0:?}")]
    HttpConnectorError(MonoioTransportError),
    #[cfg(any(feature = "hyper", feature = "pool-hyper", feature = "hyper-tls"))]
    #[error("hyper poll error: {0:?}")]
    HyperPollError(HyperError<PollConnectError<std::io::Error>>),
    #[cfg(feature = "hyper-tls")]
    #[error("Hyper TLS stream error: {0:?}")]
    TlsStreamError(HyperError<TlsError>),
}

impl From<TransportError> for Error {
    fn from(err: TransportError) -> Self {
        Error::TransportError(err)
    }
}