axum-cometd 0.5.0

Framework for CometD server creation
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

mod http_handler_error;

use tokio::sync::mpsc as TokioMpsc;

pub(crate) use http_handler_error::*;

/// Error returned by the `LongPoolingServiceContext::send`.
#[derive(Debug, thiserror::Error)]
#[error("internal error, channel closed")]
pub struct SendError;

impl<Msg> From<TokioMpsc::error::SendError<Msg>> for SendError {
    fn from(_: TokioMpsc::error::SendError<Msg>) -> Self {
        Self
    }
}

impl<Msg> From<async_broadcast::SendError<Msg>> for SendError {
    fn from(_: async_broadcast::SendError<Msg>) -> Self {
        Self
    }
}