Struct StreamingJsonDecoder 

pub struct StreamingJsonDecoder { /* private fields */ }

Streaming JSON decoder for Server-Sent Events (SSE)

This decoder handles newline-delimited JSON streams commonly used in HTTP/SSE transports.

Security

The decoder enforces a maximum buffer size of 1MB to prevent denial-of-service attacks via unbounded memory consumption. If an attacker sends continuous data without newlines, the buffer will be cleared after exceeding the limit.

Implementations

impl StreamingJsonDecoder

pub fn new() -> Self

Create a new streaming decoder with default 1MB buffer limit

pub fn with_capacity(capacity: usize) -> Self

Create with pre-allocated buffer capacity and default limit

pub fn with_max_size(max_size: usize) -> Self

Create with custom maximum buffer size

Arguments

• max_size - Maximum buffer size in bytes (capped at 10MB for safety)

Security

Setting this too high may allow DoS attacks via memory exhaustion. The value is capped at 10MB regardless of input.

pub fn feed(&mut self, data: &[u8])

Feed data into the decoder

Security

If the buffer exceeds the maximum size, it will be cleared and an error will be returned on the next try_decode call.

pub fn try_decode<T: DeserializeOwned>(&mut self) -> CodecResult<Option<T>>

Try to decode the next complete message

Returns Some(T) if a complete message is available, None if more data is needed.

pub fn clear(&mut self)

Clear the internal buffer

pub fn is_empty(&self) -> bool

Check if buffer is empty

pub fn len(&self) -> usize

Get current buffer length

pub fn max_buffer_size(&self) -> usize

Get maximum buffer size

Trait Implementations

impl Debug for StreamingJsonDecoder

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

Formats the value using the given formatter.

impl Default for StreamingJsonDecoder

fn default() -> Self

Returns the “default value” for a type.