Struct ConnectionWriteBuffer 

pub struct ConnectionWriteBuffer { /* private fields */ }

Per-connection write buffer with coalescing and flush management.

Implementations

impl ConnectionWriteBuffer

pub fn new(connection_id: u64, config: CoalesceConfig) -> Self

Create a new connection write buffer.

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

Write data to the buffer.

pub fn write_bytes(&mut self, data: Bytes)

Write owned bytes.

pub fn should_flush(&self) -> bool

Check if ready to flush.

pub fn take_all(&mut self) -> Vec<Bytes>

Get all data ready for writing.

pub fn as_io_slices(&self) -> Vec<IoSlice<'_>>

Get IoSlices for all pending data.

pub fn pending_bytes(&self) -> usize

Get total pending bytes.

pub fn flushes(&self) -> usize

Get number of flushes.

pub fn reset(&mut self)

Reset the buffer.

Trait Implementations

impl Debug for ConnectionWriteBuffer

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

Formats the value using the given formatter.