Struct salvo_core::prelude::Server

pub struct Server<L> { /* private fields */ }

HTTP Server

A Server is created to listen on a port, parse HTTP requests, and hand them off to a Service.

Implementations

impl<L> Server<L> where
    L: Listener,
    L::Conn: Transport + Send + Unpin + 'static,
    L::Error: Into<Box<dyn StdError + Send + Sync + 'static>>, 

pub fn new(listener: L) -> Self

Create new Server with Listener.

Example

Server::new(TcpListener::bind("0.0.0.0:7878"));

pub async fn serve<S>(self, service: S) where
    S: Into<Service>, 

Serve a Service

pub async fn try_serve<S>(self, service: S) -> Result<(), Error> where
    S: Into<Service>, 

Try to serve a Service

pub async fn serve_with_graceful_shutdown<S, G>(self, addr: S, signal: G) where
    S: Into<Service>,
    G: Future<Output = ()> + Send + 'static, 

Serve with graceful shutdown signal.

Example

use salvo_core::prelude::*;

#[fn_handler]
async fn hello_world(res: &mut Response) {
    res.render("Hello World!");
}

#[tokio::main]
async fn main() {
    let (tx, rx) = oneshot::channel();
    let router = Router::new().get(hello_world);
    let server = Server::new(TcpListener::bind("127.0.0.1:7878")).serve_with_graceful_shutdown(router, async {
        rx.await.ok();
    });

    // Spawn the server into a runtime
    tokio::task::spawn(server);

    // Later, start the shutdown...
    let _ = tx.send(());
}

pub async fn try_serve_with_graceful_shutdown<S, G>(
    self,
    service: S,
    signal: G
) -> Result<(), Error> where
    S: Into<Service>,
    G: Future<Output = ()> + Send + 'static, 

Serve with graceful shutdown signal.