Struct ResponseReader 

pub struct ResponseReader { /* private fields */ }

Sans-IO HTTP/1.x response parser.

Usage

use nexus_web::http::ResponseReader;

let mut reader = ResponseReader::new(4096);
reader.read(b"HTTP/1.1 101 Switching Protocols\r\nUpgrade: websocket\r\n\r\n").unwrap();
let resp = reader.next().unwrap().unwrap();
assert_eq!(resp.status, 101);
assert_eq!(resp.header("Upgrade"), Some("websocket"));

Implementations

impl ResponseReader

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 max_body_size(self, n: usize) -> Self

Set maximum response body size. Default: 0 (no limit).

When set, responses with Content-Length exceeding this value will be rejected during validation.

pub fn max_body_size_limit(&self) -> usize

Configured maximum body size (0 = no limit).

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

Buffer wire bytes.

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_from<R: Read>(&mut self, src: &mut R) -> Result<usize>

Read bytes from a source directly into the internal buffer.

Returns bytes read, or 0 on EOF.

pub fn body_remaining(&self) -> usize

Bytes of data buffered beyond the parsed headers (body bytes). Available after next() returns Some.

pub fn header(&self, name: &str) -> Option<&str>

Look up a parsed response header by name (case-insensitive).

Returns None if headers haven’t been parsed yet or the header is not found. Only valid after next() returns Some.

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

Parse the next response.

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

Bytes after the parsed head.

pub fn status(&self) -> u16

HTTP status code from parsed headers.

pub fn header_count(&self) -> usize

Number of parsed headers.

pub fn content_length(&self) -> Option<Result<usize, ()>>

Cached Content-Length from parsed headers. None = header absent, Some(Ok(n)) = valid, Some(Err(())) = present but malformed.

pub fn is_chunked(&self) -> bool

Whether Transfer-Encoding includes “chunked” (cached from parse).

pub fn set_body_consumed(&mut self, raw_bytes: usize)

Set the raw wire bytes consumed for the response body.

For Content-Length responses: equals Content-Length. For chunked responses: includes chunk framing overhead. For bodyless (1xx/204/304): 0.

Must be called before consume_response().

pub fn consume_response(&mut self)

Advance past a consumed response, preserving any pipelined bytes.

Uses last_raw_body_bytes (set via set_body_consumed) to determine how many wire bytes to skip. Call before parsing the next response on a keep-alive connection.

pub fn reset(&mut self)

Reset for a new response. Discards all buffered data.

Trait Implementations

impl ParserSink for ResponseReader

Lets a WireStream feed bytes directly into the ResponseReader’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().