TCP echo

client.rs

use std::io::{BufRead, BufReader, Write};
use std::net::TcpStream;
use std::process::exit;

fn main() {
    let addr: u16 = 12345;
    // let args = env::args().skip(1).collect::<Vec<_>>().join(" ");
    let mut stream = match TcpStream::connect(("localhost", addr)) {
        Ok(s) => s,
        Err(e) => {
            println!("Could not connect to port {}: {}", addr, e);
            exit(1);
        },
    };

    stream.write_all(b"Test\n").unwrap();

    let bufreader = BufReader::new(stream);
    for line in bufreader.lines().filter_map(Result::ok) {
        println!("{}", line)
    }
}

server.rs

use std::io::{Read, Write};
use std::net::TcpListener;
use std::process::exit;
use std::thread;

fn main() {
    let addr: u16 = 12345;
    let listener = match TcpListener::bind(("localhost", addr)) {
        Ok(s) => {
            println!("Listening on port {}", addr);
            s
        },
        Err(e) => {
            println!("Error listening on port {}: {}", addr, e);
            exit(1);
        },
    };

    for stream in listener.incoming() {
        if let Ok(mut out) = stream {
            thread::spawn(move || {
                if let Ok(mut inp) = out.try_clone() {
                    let mut buffer: Vec<u8> = Vec::new();
                    let _ = inp.read_to_end(&mut buffer);
                    let _ = out.write_all(&buffer);
                }
            });
        }
    }
}