Struct Server

Source

pub struct Server<'a> { /* private fields */ }

Expand description

A listening HTTP server that accepts HTTP 1 connections.

Implementations§

Source §

impl<'a> Server<'a>

Source

pub fn builder() -> ServerBuilder

Starts the ServerBuilder.

Source

pub fn bind<A>(addr: A) -> Server<'static>
where A: ToSocketAddrs,

Binds the Server to the given addr.

§Panics

This method will panic if binding to the address fails. For a non panic method to bind the server, see ServerBuilder::try_bind.

Examples found in repository ?

examples/routing.rs (line 15)

8fn main() -> std::io::Result<()> {
9    let router = Router::new()
10        .route("/hello", get(hello_world).post(hello_post))
11        .route("/hello", put(put_hello_world).any(any_hello))
12        .route("/hi", get(|| "Hi world"))
13        .route("/world", get(world));
14
15    Server::bind("0.0.0.0:4444").serve(router)
16}

Source

pub fn serve<S>(self, service: S) -> Result<(), Error>
where S: Service + Send + Clone + 'static,

Serves an Service on a thread per connection model, backed by a thread pool.

§Example

Server::bind("0.0.0.0:4444").serve(|req: Request<_>| {
    Response::builder()
        .status(StatusCode::OK)
        .body(req.into_body())
})

Examples found in repository ?

examples/routing.rs (line 15)

8fn main() -> std::io::Result<()> {
9    let router = Router::new()
10        .route("/hello", get(hello_world).post(hello_post))
11        .route("/hello", put(put_hello_world).any(any_hello))
12        .route("/hi", get(|| "Hi world"))
13        .route("/world", get(world));
14
15    Server::bind("0.0.0.0:4444").serve(router)
16}

Source

pub fn serve_single_thread<S>(self, service: S) -> Result<(), Error>
where S: Service + Clone,

Serves an Service on a single thread. This is useful when your Service is not Send. Note that if a connection is kept alive on this mode, no other request may be served before the said connection is closed.

§Example

Server::bind("0.0.0.0:4444").serve_single_thread(|req: Request<_>| {
    Response::builder()
        .status(StatusCode::OK)
        .body(req.into_body())
})

Source

pub fn make_service<M>(self, make_service: M) -> Result<(), Error>
where M: MakeService + Clone + 'static, <M as MakeService>::Service: Send,

Serves an Connection. This should be used when you need to execute some logic on every connection.

§Example

Server::builder()
    .bind("0.0.0.0:4444")
    .make_service(|conn: &Connection| {
        println!("New connection arrived: {:?}", conn.peer_addr());

        Ok::<_, Infallible>(|_req| {
            Response::builder()
                .status(StatusCode::OK)
                .body(())
        })
    })