smalltalk 0.3.0

Utilities for speeding up development of simple networked applications
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

pub mod read;
pub mod write;
pub mod interface;

use serde::{de::DeserializeOwned, Serialize};
use tokio::net::TcpStream;

pub use read::Reader;
pub use write::Writer;

/// Splits a `TcpStream` into a `Reader` and `Writer`
pub fn split_stream<H, M, O>(stream: TcpStream, seri_opt: O) -> (Reader<H, M, O>, Writer<H, M, O>)
where
    H: crate::header::IsHeader + Clone,
    M: Serialize + DeserializeOwned,
    O: bincode::Options + Clone,
{
    let (read_half, write_half) = stream.into_split();
    (
        Reader::new(read_half, seri_opt.clone()),
        Writer::new(write_half, seri_opt),
    )
}

/// Attempts to join a `Reader` and `Writer` into a `TcpStream`
///
/// # Errors
/// if the halfs did not originate from the same `TcpStream`
pub fn join_stream<H, M, O>(
    read_half: Reader<H, M, O>,
    write_half: Writer<H, M, O>,
) -> Result<TcpStream, tokio::net::tcp::ReuniteError>
where
    H: crate::header::IsHeader + Clone,
    M: Serialize + DeserializeOwned,
    O: bincode::Options + Clone,
{
    read_half.into_socket().reunite(write_half.into_socket())
}