Struct RequestReader 

pub struct RequestReader { /* private fields */ }

Sans-IO HTTP/1.x request parser.

Usage

use nexus_web::http::RequestReader;

let mut reader = RequestReader::new(4096);
reader.read(b"GET / HTTP/1.1\r\nHost: example.com\r\n\r\n").unwrap();
let req = reader.next().unwrap().unwrap();
assert_eq!(req.method, "GET");
assert_eq!(req.path, "/");
assert_eq!(req.header("Host"), Some("example.com"));

Implementations

impl RequestReader

pub fn new(capacity: usize) -> Self

Create with the given buffer capacity.

pub fn max_headers(self, n: usize) -> Self

Set maximum number of headers. Default: 64.

pub fn max_head_size(self, n: usize) -> Self

Set maximum head size. Default: 8KB.

pub fn spare(&mut self) -> &mut [u8]

Writable region for direct in-buffer writes. Pair with filled() to commit bytes after the write. Used by crate::WireStream to deliver bytes from a transport without a slice intermediate.

pub fn filled(&mut self, n: usize)

Commit n bytes written into spare().

pub fn read(&mut self, src: &[u8]) -> Result<(), HttpError>

Buffer wire bytes.

pub fn next(&mut self) -> Result<Option<Request<'_>>, HttpError>

Parse the next request.

Returns Ok(Some(request)) when the head is complete. Returns Ok(None) if more bytes are needed.

pub fn remainder(&self) -> &[u8]

Bytes after the parsed head.

pub fn reset(&mut self)

Reset for a new request.

Trait Implementations

impl ParserSink for RequestReader

Lets a WireStream feed bytes directly into the RequestReader’s spare region — one fewer copy than going through a slice intermediary.

fn spare(&mut self) -> &mut [u8]

Writable region where new bytes go.

fn filled(&mut self, n: usize)

Commit n bytes written into spare().