tcp_channel/
channel.rs

1use std::sync::mpsc::{Sender as StdSender, Receiver as StdReceiver, SendError as StdSendError, RecvError as StdRecvError};
2
3pub trait ChannelSend<T> {
4    type Error;
5    fn send(&mut self, value: &T) -> Result<(), Self::Error>;
6}
7pub trait ChannelRecv<T> {
8    type Error;
9    fn recv(&mut self) -> Result<T, Self::Error>;
10}
11
12impl<T: Clone> ChannelSend<T> for StdSender<T> {
13    type Error = StdSendError<T>;
14
15    fn send(&mut self, value: &T) -> Result<(), Self::Error> {
16        StdSender::send(self, value.clone())
17    }
18}
19impl<T> ChannelRecv<T> for StdReceiver<T> {
20    type Error = StdRecvError;
21
22    fn recv(&mut self) -> Result<T, Self::Error> {
23        StdReceiver::recv(self)
24    }
25}
tcp_channel/channel.rs

tcp_channel/
channel.rs
