channel-sender 0.4.0

Channel Sender
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use dyn_clone::{clone_trait_object, DynClone};

use crate::error::{SendError, SendErrorWithoutFull};

//
#[async_trait::async_trait]
pub trait BoundedSender<T>: DynClone {
    async fn send(&self, t: T) -> Result<(), SendErrorWithoutFull<T>>
    where
        T: Send;

    fn try_send(&self, t: T) -> Result<(), SendError<T>>;
}
clone_trait_object!(<T> BoundedSender<T>);

pub trait UnboundedSender<T>: DynClone {
    fn send(&self, t: T) -> Result<(), SendErrorWithoutFull<T>>;
}
clone_trait_object!(<T> UnboundedSender<T>);