server/
server.rs

1use send_it::Segment;
2
3fn main() {
4    // create a TcpListener
5    let listener = std::net::TcpListener::bind("0.0.0.0:3333").expect("Failed to start tcp listener!");
6    println!("Listening on :3333");
7
8    // listen for incoming connections
9    for stream in listener.incoming() {
10        let mut stream = stream.expect("Invalid stream!");
11        
12        // handle a new connection
13        std::thread::spawn(move || {
14            // create a reader for the TcpStream
15            let mut reader = send_it::reader::VarReader::new(&mut stream);
16            // loop while there is incoming data
17            while let Ok(data) = reader.read_data() {
18                // convert our segments to strings in the vector
19                let readable_data = Segment::to_readable(data);
20                
21                // print out the vector of strings
22                println!("Segments from client: [{}]", readable_data.join(", "));
23            }
24            println!("Connection closed!");
25        });
26    }
27}
server/server.rs

server/
server.rs
