Further step to working keep-alive

Author: rylev

Cargo.toml

@@ -15,7 +15,7 @@ edition = "2018"
 httparse = "1.3.3"
 http = "0.1.17"
 futures-io = "0.3.0"
-async-std = "0.99.12"
+async-std = { version = "0.99.12", features = ["unstable"] }
 futures-core-preview = "0.3.0-alpha.18"
 
 [dev-dependencies]

src/server.rs

@@ -1,10 +1,10 @@
 //! Process HTTP connections on the server.
 
-use async_std::future::{timeout, Future};
+use async_std::future::Future;
 use async_std::io::{self, BufReader};
 use async_std::io::{Read, Write};
 use async_std::prelude::*;
-use async_std::task::{Context, Poll};
+use async_std::task::{sleep, Context, Poll};
 use futures_core::ready;
 use http::{Request, Response, Version};
 
@@ -34,14 +34,20 @@ where
                 let reader = res.body.into_reader().unwrap();
                 let decoder = Decoder::new(reader);
                 match decoder.decode().await? {
-                    // TODO: no unwrap
                     Some(r) => req = r,
                     None => break,
                 }
             }
 
             Ok::<(), Exception>(())
         };
+
+        let timer = async {
+            sleep(std::time::Duration::from_secs(5)).await;
+            Ok::<(), Exception>(())
+        };
+
+        handle.race(timer).await?;
     }
 
     Ok(())