Struct StreamState 

pub struct StreamState {
    pub id: u16,
    pub status: StreamStatus,
    pub send_buffer: VecDeque<Bytes>,
    pub recv_buffer: VecDeque<Bytes>,
    pub window_size: u32,
    pub bytes_sent: AtomicU64,
    pub bytes_received: AtomicU64,
    pub error: Option<String>,
    /* private fields */
}

Stream state

Fields

id: u16

Stream ID

status: StreamStatus

Current status

send_buffer: VecDeque<Bytes>

Send buffer

recv_buffer: VecDeque<Bytes>

Receive buffer

window_size: u32

Flow control window size

bytes_sent: AtomicU64

Bytes sent

bytes_received: AtomicU64

Bytes received

error: Option<String>

Error message if stream was reset

Implementations

impl StreamState

pub fn new(id: u16) -> Self

Create a new stream state

pub fn queue_send(&mut self, data: Bytes) -> Result<(), MultiplexError>

Queue data for sending

pub fn queue_recv( &mut self, data: Bytes, max_recv_buffer_bytes: usize, ) -> Result<(), MultiplexError>

Queue received data

pub fn take_send(&mut self) -> Option<Bytes>

Take next data from send buffer

pub fn take_recv(&mut self) -> Option<Bytes>

Take next data from receive buffer

pub fn close_local(&mut self)

Close local side of stream

pub fn close_remote(&mut self)

Close remote side of stream

pub fn reset(&mut self, error: Option<String>)

Reset stream with error