Struct Server 

pub struct Server<const STACK_SIZE: usize> { /* private fields */ }

A threadpool-based HTTP server

Implementations

impl<const STACK_SIZE: usize> Server<STACK_SIZE>

pub fn with_source_sink<F>(workers_max: usize, source_sink_handler: F) -> Self

where F: Fn(&mut Source, &mut Sink) -> bool + Send + Sync + 'static,

Creates a new server with the given connection handler

pub fn with_request_response<F>( workers_max: usize, request_response_handler: F, ) -> Self

where F: Fn(Request<'_>) -> Response + Send + Sync + 'static,

Creates a new server with the given connection handler

Examples found in repository

examples/helloworld.rs (lines 7-11)

fn main() {
    use ehttpd::Server;
    use ehttpd::http::{Response, ResponseExt};

    // Create a server that listens at [::]:9999 with up to 2048 worker threads under load if necessary
    let server = Server::with_request_response(2048, |_| {
        let mut response = Response::new_200_ok();
        response.set_body_data(b"Hello world\r\n");
        response
    });

    // Handle incoming connections
    server.accept("[::]:9999").expect("server failed");
}

examples/helloworld-nokeepalive.rs (lines 7-12)

fn main() {
    use ehttpd::Server;
    use ehttpd::http::{Response, ResponseExt};

    // Create a server that listens at [::]:9999 with up to 2048 worker threads under load if necessary
    let server = Server::with_request_response(2048, |_| {
        let mut response = Response::new_200_ok();
        response.set_body_data(b"Hello world\r\n");
        response.set_connection_close();
        response
    });

    // Handle incoming connections
    server.accept("[::]:9999").expect("server failed");
}

examples/teapot.rs (lines 7-17)

fn main() {
    use ehttpd::Server;
    use ehttpd::http::{Response, ResponseExt};

    // Create a server that listens at [::]:9999 with up to 2048 worker threads under load if necessary
    let server = Server::with_request_response(2048, |request| {
        // Create the response body
        let mut message = b"There are only teapots in ".to_vec();
        message.extend_from_slice(&request.target);
        message.extend_from_slice(b"\r\n");

        // Send the response
        let mut response = Response::new_status_reason(418, "I'm a teapot");
        response.set_body_data(message);
        response
    });

    // Handle incoming connections
    server.accept("[::]:9999").expect("server failed");
}

pub fn dispatch(&self, source: Source, sink: Sink) -> Result<(), Error>

Manually dispatches a connection

pub fn accept<A>(self, address: A) -> Result<Infallible, Error>

where A: ToSocketAddrs,

Listens on the given address and accepts forever

Examples found in repository

examples/helloworld.rs (line 14)

fn main() {
    use ehttpd::Server;
    use ehttpd::http::{Response, ResponseExt};

    // Create a server that listens at [::]:9999 with up to 2048 worker threads under load if necessary
    let server = Server::with_request_response(2048, |_| {
        let mut response = Response::new_200_ok();
        response.set_body_data(b"Hello world\r\n");
        response
    });

    // Handle incoming connections
    server.accept("[::]:9999").expect("server failed");
}

examples/helloworld-nokeepalive.rs (line 15)

fn main() {
    use ehttpd::Server;
    use ehttpd::http::{Response, ResponseExt};

    // Create a server that listens at [::]:9999 with up to 2048 worker threads under load if necessary
    let server = Server::with_request_response(2048, |_| {
        let mut response = Response::new_200_ok();
        response.set_body_data(b"Hello world\r\n");
        response.set_connection_close();
        response
    });

    // Handle incoming connections
    server.accept("[::]:9999").expect("server failed");
}

examples/teapot.rs (line 20)

fn main() {
    use ehttpd::Server;
    use ehttpd::http::{Response, ResponseExt};

    // Create a server that listens at [::]:9999 with up to 2048 worker threads under load if necessary
    let server = Server::with_request_response(2048, |request| {
        // Create the response body
        let mut message = b"There are only teapots in ".to_vec();
        message.extend_from_slice(&request.target);
        message.extend_from_slice(b"\r\n");

        // Send the response
        let mut response = Response::new_status_reason(418, "I'm a teapot");
        response.set_body_data(message);
        response
    });

    // Handle incoming connections
    server.accept("[::]:9999").expect("server failed");
}