tropocol 0.1.1

Send and receive serde-compatible objects over TCP (async)
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

use super::{TcpStream, SendFut, Serialize, Deserialize};
use ::async_fifo::{Sender, Receiver};

/// Object which produces outgoing messages
impl<O: Send + Unpin> super::GetOutgoing<O> for Receiver<O> {
    async fn get_outgoing(&mut self) -> Option<O> {
        self.recv().await.ok()
    }
}

/// Object which handles incoming messages
impl<I: Send> super::HandleIncoming<I> for Sender<I> {
    async fn handle_incoming(&mut self, incoming: I) {
        self.send(incoming);
    }
}

pub fn session<O, I>(tcp_stream: TcpStream) -> (impl SendFut<Result<(), ()>>, Sender<O>, Receiver<I>)
where
    O: Send + Unpin + Serialize + 'static,
    I: Send + for<'a> Deserialize<'a> + 'static,
{
    let (tx_outgoing, rx_outgoing) = ::async_fifo::new();
    let (tx_incoming, rx_incoming) = ::async_fifo::new();

    let task = super::raw::session(tcp_stream, tx_incoming, rx_outgoing);

    (task, tx_outgoing, rx_incoming)
}