This does not yet handle requests concurrently. Demonstrate with adding
a /sleep path.
[dependencies]
log = "0.4"
env_logger = "0.9"
[dependencies]
log = "0.4"
env_logger = "0.9"
+
+[dependencies.async-std]
+version = "1.6"
+features = ["attributes"]
use std::fs;
use std::io::prelude::*;
use std::fs;
use std::io::prelude::*;
-use std::net::TcpListener;
-use std::net::TcpStream;
+use std::net::{ TcpListener, TcpStream };
+use std::time::Duration;
+use async_std::task;
+
+#[async_std::main]
+async fn main() {
env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("info")).init();
// Listen for incoming TCP connections on localhost port 7878
env_logger::Builder::from_env(env_logger::Env::default().default_filter_or("info")).init();
// Listen for incoming TCP connections on localhost port 7878
// Block forever, handling each request that arrives at this IP address
for stream in listener.incoming() {
let stream = stream.unwrap();
// Block forever, handling each request that arrives at this IP address
for stream in listener.incoming() {
let stream = stream.unwrap();
- handle_connection(stream);
+ // not concurrent
+ handle_connection(stream).await;
-fn handle_connection(mut stream: TcpStream) {
+async fn handle_connection(mut stream: TcpStream) {
// Read the first 1024 bytes of data from the stream
let mut buffer = [0; 1024];
assert!(stream.read(&mut buffer).unwrap() > 0);
// Read the first 1024 bytes of data from the stream
let mut buffer = [0; 1024];
assert!(stream.read(&mut buffer).unwrap() > 0);
- let get = b"GET / HTTP/1.1\r\n";
-
// Respond with greetings or a 404,
// depending on the data in the request
// Respond with greetings or a 404,
// depending on the data in the request
- let (status_line, filename) = if buffer.starts_with(get) {
+ let (status_line, filename) = if buffer.starts_with(b"GET / HTTP/1.1\r\n") {
("HTTP/1.1 200 OK", "index.html")
("HTTP/1.1 200 OK", "index.html")
+ } else if buffer.starts_with(b"GET /sleep HTTP/1.1\r\n") {
+ task::sleep(Duration::from_secs(5)).await;
+ ("HTTP/1.1 201 Sleep", "index.html")
} else {
("HTTP/1.1 404 NOT FOUND", "404.html")
};
} else {
("HTTP/1.1 404 NOT FOUND", "404.html")
};