[rustc.git] / src / doc / book / listings / ch20-web-server / listing-20-03 / src / main.rs

use std::{
    io::{prelude::*, BufReader},
    net::{TcpListener, TcpStream},
};

fn main() {
    let listener = TcpListener::bind("127.0.0.1:7878").unwrap();

    for stream in listener.incoming() {
        let stream = stream.unwrap();

        handle_connection(stream);
    }
}

// ANCHOR: here
fn handle_connection(mut stream: TcpStream) {
    let buf_reader = BufReader::new(&mut stream);
    let http_request: Vec<_> = buf_reader
        .lines()
        .map(|result| result.unwrap())
        .take_while(|line| !line.is_empty())
        .collect();

    let response = "HTTP/1.1 200 OK\r\n\r\n";

    stream.write_all(response.as_bytes()).unwrap();
}
// ANCHOR_END: here
Commit	Line	Data
923072b8 FG	1	use std::{
	2	io::{prelude::*, BufReader},
	3	net::{TcpListener, TcpStream},
	4	};
74b04a01 XL	5
	6	fn main() {
	7	let listener = TcpListener::bind("127.0.0.1:7878").unwrap();
	8
	9	for stream in listener.incoming() {
	10	let stream = stream.unwrap();
	11
	12	handle_connection(stream);
	13	}
	14	}
	15
	16	// ANCHOR: here
	17	fn handle_connection(mut stream: TcpStream) {
923072b8 FG	18	let buf_reader = BufReader::new(&mut stream);
	19	let http_request: Vec<_> = buf_reader
	20	.lines()
	21	.map(\|result\| result.unwrap())
	22	.take_while(\|line\| !line.is_empty())
	23	.collect();
74b04a01 XL	24
	25	let response = "HTTP/1.1 200 OK\r\n\r\n";
	26
923072b8	27	stream.write_all(response.as_bytes()).unwrap();
74b04a01 XL	28	}
74b04a01 XL	29	// ANCHOR_END: here