Struct MessageAssembler 

pub struct MessageAssembler { /* private fields */ }

Reassembles multiple TDS packets into complete messages.

TDS messages are framed with the END_OF_MESSAGE status flag on the final packet. This assembler buffers packets until a complete message is received.

Implementations

impl MessageAssembler

pub fn new() -> Self

Create a new message assembler.

pub fn with_capacity(capacity: usize) -> Self

Create a new message assembler with pre-allocated capacity.

pub fn push(&mut self, packet: Packet) -> Option<Message>

Push a packet into the assembler.

Returns Some(Message) if this packet completes a message, None if more packets are needed.

pub fn has_partial(&self) -> bool

Check if the assembler has partial data buffered.

pub fn packet_count(&self) -> usize

Get the number of packets accumulated so far.

pub fn buffer_len(&self) -> usize

Get the current buffer length.

pub fn clear(&mut self)

Clear any partial message data.

Trait Implementations

impl Debug for MessageAssembler

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

Formats the value using the given formatter.

impl Default for MessageAssembler

fn default() -> Self

Returns the “default value” for a type.