Struct DcpStream 

pub struct DcpStream { /* private fields */ }

DCP Stream with integrity verification

Implementations

impl DcpStream

pub fn new(stream_id: u32, capacity: usize) -> Self

Create a new DCP stream with the given buffer capacity

pub fn stream_id(&self) -> u32

Get the stream ID

pub fn buffer(&self) -> &StreamRingBuffer

Get the underlying buffer

pub fn is_complete(&self) -> bool

Check if the stream is complete

pub fn write_chunk( &self, data: &[u8], is_last: bool, ) -> Result<StreamChunk, DCPError>

Write a chunk to the stream (producer side) Returns the chunk header that should be sent

pub fn read_chunk(&self) -> Result<Option<(StreamChunk, Vec<u8>)>, DCPError>

Read a chunk from the stream (consumer side) Returns the chunk header and data, or None if no data available

pub fn checksum(&self) -> [u8; 32]

Get the current checksum of all data written so far

pub fn verify_checksum(&self, expected: &[u8; 32]) -> bool

Verify the stream checksum against an expected value

pub fn request_retransmit(&self, missing_seq: u32) -> RetransmitRequest

Create a retransmission request for missing chunks

pub fn next_expected_seq(&self) -> u32

Get the next expected sequence number

pub fn next_send_seq(&self) -> u32

Get the next sequence number to send

pub fn is_backpressure(&self) -> bool

Check if backpressure is active

pub fn available_space(&self) -> usize

Get available buffer space

pub fn reset(&self)

Reset the stream for reuse