Struct SyncStream

Source

pub struct SyncStream { /* private fields */ }

Expand description

the TcpStream version of the artifice network, implements encryption automatically in its implementation of std::io::Write, and std::io::Read

Implementations§

Source §

impl SyncStream

Source

pub fn recv(&mut self, outbuf: &mut Vec<u8>) -> Result<usize, NetworkError>

implented in place of std::io::Read, because reading to empty vec fails

Examples found in repository ?

examples/client.rs (line 18)

4fn main() {
5    // this function is for testing only
6    let (mut peer, config) = test_config();
7    peer.set_socket_addr(SocketAddr::new(
8        IpAddr::V4(Ipv4Addr::new(10, 0, 0, 81)),
9        6464,
10    ));
11    let host = SyncHost::client_only(&config).unwrap();
12    let mut stream = host.connect(peer).unwrap();
13    println!("connected");
14    let mut buffer = Vec::new();
15    println!("about to read from sream");
16    println!(
17        "got {} bytes from server",
18        stream.recv(&mut buffer).unwrap()
19    );
20    println!("read from stream");
21    let string = String::from_utf8(buffer).unwrap();
22    println!("got message: {} from server", string);
23}

Source

pub fn send(&mut self, buffer: &[u8]) -> Result<usize, NetworkError>

send data to the peer

Examples found in repository ?

examples/listen.rs (line 9)

3fn main() {
4    let (peer, config) = test_config();
5    let host = SyncHost::from_host_data(&config).unwrap();
6    for netstream in host {
7        println!("new connection");
8        let mut stream = netstream.unwrap().verify(&peer).unwrap();
9        stream.send(&random_string(55555).into_bytes()).unwrap();
10        break;
11    }
12}