blob: 43bf2f6efa7248d3a4685d598b1b35f9cc6bb58e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
#![deny(warnings)]
use std::convert::Infallible;
use std::str::FromStr;
use std::time::Duration;
use warp::Filter;
#[tokio::main]
async fn main() {
// Match `/:Seconds`...
let routes = warp::path::param()
// and_then create a `Future` that will simply wait N seconds...
.and_then(sleepy);
warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;
}
async fn sleepy(Seconds(seconds): Seconds) -> Result<impl warp::Reply, Infallible> {
tokio::time::sleep(Duration::from_secs(seconds)).await;
Ok(format!("I waited {} seconds!", seconds))
}
/// A newtype to enforce our maximum allowed seconds.
struct Seconds(u64);
impl FromStr for Seconds {
type Err = ();
fn from_str(src: &str) -> Result<Self, Self::Err> {
src.parse::<u64>().map_err(|_| ()).and_then(|num| {
if num <= 5 {
Ok(Seconds(num))
} else {
Err(())
}
})
}
}
|
