generic-channel 0.2.0

Generic `Sender` and `Receiver` abstract between several channel implementations: std, crossbeam-channel, futures
Documentation
1
2
3
4
5
6
7
8
9
10
11
use crate::{Sender as SenderTrait, TrySendError};
use crossbeam_channel::{Sender, TrySendError as CBTrySendError};

impl<T> SenderTrait<T> for Sender<T> {
    fn try_send(&mut self, t: T) -> Result<(), TrySendError<T>> {
        Sender::try_send(self, t).map_err(|err| match err {
            CBTrySendError::Full(t) => TrySendError::Full(t),
            CBTrySendError::Disconnected(t) => TrySendError::Disconnected(t),
        })
    }
}