ntex_h2/server/
mod.rs

1mod service;
2pub use self::service::{Server, ServerHandler, handle_one};
3
4use crate::frame;
5
6/// Errors which can occur when attempting to handle amqp connection.
7#[derive(thiserror::Error, Debug)]
8pub enum ServerError<E> {
9    /// Request handler error
10    #[error("Message handler service error")]
11    Service(E),
12    /// Http/2 frame codec error
13    #[error("Http/2 codec error: {0}")]
14    Frame(#[from] frame::FrameError),
15    /// Dispatcher error
16    #[error("Dispatcher error")]
17    Dispatcher,
18    /// Control service init error
19    #[error("Control service init error")]
20    ControlServiceError,
21    /// Publish service init error
22    #[error("Publish service init error")]
23    PublishServiceError,
24    /// Handshake timeout
25    #[error("Handshake timeout")]
26    HandshakeTimeout,
27    /// Peer disconnect
28    #[error("Peer is disconnected, error: {0:?}")]
29    Disconnected(Option<std::io::Error>),
30}
31
32impl<E> From<std::io::Error> for ServerError<E> {
33    fn from(err: std::io::Error) -> Self {
34        ServerError::Disconnected(Some(err))
35    }
36}
ntex_h2/server/mod.rs

ntex_h2/server/
mod.rs
