Fix http server example.

This commit is contained in:
Heyang Zhou
2019-05-14 00:05:05 -07:00
parent 2963b0a2eb
commit 9df3e4af88

View File

@ -25,13 +25,19 @@ fn serve(stream: Arc<TcpStream>, mut all: Vec<u8>) {
return; return;
} }
}; };
if let Some(pos) = s.find("\r\n\r\n") { if let Some(_pos) = s.find("\r\n\r\n") {
let body = format!(
"Hello, world!\n",
).into_bytes();
let stream = stream2.clone();
stream2.write_all_async( stream2.write_all_async(
format!( format!(
"HTTP/1.0 200 OK\r\nContent-Type: text/plain\r\n\r\nYour headers: \n\n{}\n", "HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\nConnection: close\r\nContent-Length: {}\r\n\r\n",
::std::str::from_utf8(&all[..pos]).unwrap() body.len()
).into_bytes(), ).into_bytes(),
|result| {} |_| {
stream.write_all_async(body, |_| {});
}
); );
} else { } else {
schedule(|| serve(stream2, all)); schedule(|| serve(stream2, all));