Struct HttpRequestProducerConfig 

pub struct HttpRequestProducerConfig {
    pub extract_body: bool,
    pub max_body_size: Option<usize>,
    pub parse_json: bool,
    pub extract_query_params: bool,
    pub extract_path_params: bool,
    pub stream_body: bool,
    pub chunk_size: usize,
}

Configuration for HTTP request producer behavior.

Fields

extract_body: bool

Whether to extract the request body as bytes.

max_body_size: Option<usize>

Maximum body size to extract (in bytes). None means no limit.

parse_json: bool

Whether to parse JSON body automatically.

extract_query_params: bool

Whether to extract query parameters.

extract_path_params: bool

Whether to extract path parameters.

stream_body: bool

Whether to stream the request body in chunks instead of loading it all at once. When enabled, the producer will yield the request metadata first, then stream body chunks. This is memory-efficient for large request bodies.

chunk_size: usize

Chunk size for streaming (in bytes). Only used when stream_body is true.

Implementations

impl HttpRequestProducerConfig

pub fn with_extract_body(self, extract: bool) -> Self

Sets whether to extract the request body.

pub fn with_max_body_size(self, size: Option<usize>) -> Self

Sets the maximum body size to extract.

pub fn with_parse_json(self, parse: bool) -> Self

Sets whether to parse JSON body automatically.

pub fn with_extract_query_params(self, extract: bool) -> Self

Sets whether to extract query parameters.

pub fn with_extract_path_params(self, extract: bool) -> Self

Sets whether to extract path parameters.

pub fn with_stream_body(self, stream: bool) -> Self

Sets whether to stream the request body in chunks.

When enabled, the producer will yield the request metadata first, then stream body chunks. This is memory-efficient for large request bodies.

Example

use streamweave::http_server::HttpRequestProducerConfig;

let config = HttpRequestProducerConfig::default()
    .with_stream_body(true)
    .with_chunk_size(128 * 1024); // 128KB chunks

pub fn with_chunk_size(self, size: usize) -> Self

Sets the chunk size for streaming (in bytes).

Only used when stream_body is true. Default is 64KB.

Trait Implementations

impl Clone for HttpRequestProducerConfig

fn clone(&self) -> HttpRequestProducerConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for HttpRequestProducerConfig

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

Formats the value using the given formatter.

impl Default for HttpRequestProducerConfig

Available on non-WebAssembly and crate feature http-server only.

fn default() -> Self

Returns the “default value” for a type.