Struct Server 

pub struct Server {}

Implementations

impl Server

pub fn process_request( stream: impl Read + Write + Unpin, peer_addr: SocketAddr, ) -> Vec<u8>

pub fn bad_request_response(message: String) -> Vec<u8>

pub fn payload_too_large_response(message: String) -> Vec<u8>

Builds a 413 Payload Too Large raw response for a request whose declared Content-Length exceeds RWS_CONFIG_MAX_BODY_SIZE_IN_BYTES. The connection is always closed after this is sent (see Server::process) — the client’s unread body bytes are still queued on the socket, so keep-alive framing can’t be trusted.

pub fn header_fields_too_large_response() -> Vec<u8>

Builds a 431 Request Header Fields Too Large raw response for a request head longer than [framing::MAX_HEAD_SIZE]. The connection is closed after it: the rest of the oversized head is still unread.

pub fn request_timeout_response() -> Vec<u8>

Builds a 408 Request Timeout raw response for a client that started a request head but didn’t finish it within REQUEST_HEAD_TIMEOUT. The connection is closed after it.

pub fn continue_response() -> Vec<u8>

Builds the 100 Continue interim response (RFC 9110 §15.2.1) — no headers, no body, just the status line. Sent immediately after parsing a request with Expect: 100-continue, before reading its body, so the client (which is waiting for this before it uploads the body) doesn’t stall or time out. See Server::process for where this is sent from.

pub fn expectation_failed_response(message: String) -> Vec<u8>

Builds a 417 Expectation Failed raw response for an Expect header value other than 100-continue (RFC 9110 §10.1.1) — the only expectation this server understands. Sent instead of reading the request body, since the expectation can’t be met either way.

pub fn process( stream: impl Read + Write + Unpin, connection: ConnectionInfo, app: impl Application, ) -> Result<(), String>

pub fn setup() -> Result<(TcpListener, ThreadPool), String>

Reads configuration (IP, port, thread count, TLS paths) from the layered config system and returns a bound TcpListener and a sized ThreadPool. Call once at startup.

pub fn run( listener: TcpListener, pool: ThreadPool, app: impl Application + Send + 'static + Clone, )

Accepts TCP connections in a loop and dispatches each to the thread pool.

When built with the http1 feature, Ctrl+C and SIGTERM stop the accept loop gracefully: SERVER_READY is cleared and the pool drains all in-flight connections before returning.

For TLS/HTTP2/HTTP3 use [Server::run_tls].