Struct BufferedHandler 

pub struct BufferedHandler { /* private fields */ }

A handler that buffers messages in memory.

Implementations

impl BufferedHandler

pub fn new() -> Self

Create a new buffered handler.

pub fn with_max_size(max_size: usize) -> Self

Create a handler with a maximum buffer size.

pub fn messages(&self) -> Vec<StreamMessage>

Get all buffered messages.

pub fn clear(&self)

Clear the buffer.

pub fn len(&self) -> usize

Get the number of buffered messages.

pub fn is_empty(&self) -> bool

Check if the buffer is empty.

Trait Implementations

impl Default for BufferedHandler

fn default() -> Self

Returns the “default value” for a type.

impl StreamHandler for BufferedHandler

fn handle(&self, message: &StreamMessage)

Process a stream message.

fn should_handle(&self, _message: &StreamMessage) -> bool

Filter predicate - return false to skip handling this message.

fn flush(&self)

Flush any buffered output.

fn on_start(&self, _job_id: &str)

Called when streaming starts.

fn on_end(&self, _job_id: &str, _final_status: Option<&str>)

Called when streaming ends.