notifier_hub 0.1.2

A simple cannal subscribtion system
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

use thiserror::Error;
use tokio::{sync::mpsc::error::SendError, task::JoinError, time::Duration};

#[macro_export]
macro_rules! unexpected {
    ($kind:ident) => {
        return Err(NotifierError::UnexpectedError(UnexpectedErrorKind::$kind))
    };
}

#[derive(Debug)]
pub enum UnexpectedErrorKind {
    DurationIsMissing,
    InvalidChannelStateUnsubscribe,
    SenderIsMissing,
}

#[derive(Debug, Error)]
pub enum NotifierError<M, ChannelId> {
    #[error("Failed to send a message via tokio channel beacause of this: {0:?}")]
    SendingError(SendError<M>),
    #[error("Failed to wait for a writing because of this: {0:?}")]
    JoiningError(JoinError),
    /// This one returns a vector conaining all the send errors and join errors during the writing phase
    #[error("Failed to send a message from the writing handler due to this: {0:?}")]
    WritingSendError(Vec<NotifierError<M, ChannelId>>),
    #[error("Timeout during the wait of a writing task, duration: {0:?}")]
    WritingTimeout(Duration),
    #[error("This error was not expected. Please report an issue to https://github.com/ZivoMartin/AsyncForge with this code: {0:?}")]
    UnexpectedError(UnexpectedErrorKind),
    #[error("The given receiver is no subscribed to the channel {0:?}")]
    NotSubscribed(ChannelId),
    #[error("The given receiver is no subscribed to this channels: {0:?}")]
    NotSubscribedMultiple(Vec<NotifierError<M, ChannelId>>),
    #[error("The channel {0:?} has not been initialized")]
    ChannelUninitialized(ChannelId),
    #[error("The channel {0:?} is over")]
    ChannelOver(ChannelId),
    #[error("The channel {0:?} does not exist")]
    ChannelNotExist(ChannelId),
}