Struct http_service_h1::Server

pub struct Server<I, S: HttpService> { /* fields omitted */ }

A listening HTTP server that accepts connections in HTTP1.

Methods

impl<I: Stream<Item = Result<TcpStream>>, S: HttpService> Server<I, S> where
    <<S as HttpService>::ResponseFuture as Future>::Output: Send,
    <S as HttpService>::Connection: Sync,
    I: Unpin + Send + Sync, 

pub fn new(addr: String, incoming: I, service: S) -> Self

Consume this [Builder], creating a Server.

Examples

use http_service::{Response, Body};
use http_service_h1::Server;
use async_std::net::TcpListener;

// And an HttpService to handle each connection...
let service = |req| async {
    Ok::<Response, async_std::io::Error>(Response::from("Hello World"))
};

async_std::task::block_on(async move {
    // Then bind, configure the spawner to our pool, and serve...
    let mut listener = TcpListener::bind("127.0.0.1:3000").await?;
    let addr = format!("http://{}", listener.local_addr()?);
    let mut server = Server::new(addr, listener.incoming(), service);
    server.run().await?;
    Ok::<(), Box<dyn std::error::Error>>(())
})?;

pub async fn run<'_>(&'_ mut self) -> Result<()>

Run the server forever-ish.

Trait Implementations

impl<I: Debug, S: Debug + HttpService> Debug for Server<I, S>

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

Formats the value using the given formatter.