Function warp::serve

source · [−]
pub fn serve<F>(filter: F) -> Server<F> where
    F: Filter + Clone + Send + Sync + 'static,
    F::Extract: Reply,
    F::Error: IsReject, 
Expand description

Create a Server with the provided Filter.

Examples found in repository?
examples/returning.rs (line 19)
17
18
19
20

async fn main() {
    let routes = index_filter().or(assets_filter());
    warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;
}
More examples
Hide additional examples
examples/dyn_reply.rs (line 16)
13
14
15
16
17

async fn main() {
    let routes = warp::path::param().and_then(dyn_reply);

    warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;
}
examples/dir.rs (line 7)
4
5
6
7
8
9
10

async fn main() {
    pretty_env_logger::init();

    warp::serve(warp::fs::dir("examples/dir"))
        .run(([127, 0, 0, 1], 3030))
        .await;
}
examples/hello.rs (line 9)
5
6
7
8
9
10

async fn main() {
    // Match any request and return hello world!
    let routes = warp::any().map(|| "Hello, World!");

    warp::serve(routes).run(([127, 0, 0, 1], 3030)).await;
}
examples/futures.rs (line 15)
9
10
11
12
13
14
15
16

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;
}
examples/unix_socket.rs (line 12)
7
8
9
10
11
12
13
14
15

async fn main() {
    pretty_env_logger::init();

    let listener = UnixListener::bind("/tmp/warp.sock").unwrap();
    let incoming = UnixListenerStream::new(listener);
    warp::serve(warp::fs::dir("examples/dir"))
        .run_incoming(incoming)
        .await;
}
Additional examples can be found in: