Struct Serve

pub struct Serve<M, S> { /* private fields */ }

Available on crate feature tokio and (crate features http1 or http2) only.

Future returned by serve.

Implementations

impl<M, S> Serve<M, S>

pub fn with_graceful_shutdown<F>( self, signal: F, ) -> WithGracefulShutdown<M, S, F>

where F: Future<Output = ()> + Send + 'static,

Prepares a server to handle graceful shutdown when the provided future completes.

Example

use axum::{Router, routing::get};

let router = Router::new().route("/", get(|| async { "Hello, World!" }));

let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap();
axum::serve(listener, router)
    .with_graceful_shutdown(shutdown_signal())
    .await
    .unwrap();

async fn shutdown_signal() {
    // ...
}

pub fn tcp_nodelay(self, nodelay: bool) -> Self

Instructs the server to set the value of the TCP_NODELAY option on every accepted connection.

See also TcpStream::set_nodelay.

Example

use axum::{Router, routing::get};

let router = Router::new().route("/", get(|| async { "Hello, World!" }));

let listener = tokio::net::TcpListener::bind("0.0.0.0:3000").await.unwrap();
axum::serve(listener, router)
    .tcp_nodelay(true)
    .await
    .unwrap();

pub fn local_addr(&self) -> Result<SocketAddr>

Returns the local address this server is bound to.

Trait Implementations

impl<M, S> Debug for Serve<M, S>

where M: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<M, S> IntoFuture for Serve<M, S>

where M: for<'a> Service<IncomingStream<'a>, Error = Infallible, Response = S> + Send + 'static, for<'a> <M as Service<IncomingStream<'a>>>::Future: Send, S: Service<Request, Response = Response, Error = Infallible> + Clone + Send + 'static, S::Future: Send,

type Output = Result<(), Error>

The output that the future will produce on completion.

type IntoFuture = ServeFuture

Which kind of future are we turning this into?

fn into_future(self) -> Self::IntoFuture

Creates a future from a value.