Struct Streams 

pub struct Streams {
    pub send_max_data: u64,
    pub control: VecDeque<Control>,
    pub events: VecDeque<StreamEvent>,
    /* private fields */
}

Fields

send_max_data: u64

control: VecDeque<Control>

events: VecDeque<StreamEvent>

Implementations

impl Streams

pub fn new(is_server: bool, cfg: StreamConfig) -> Self

pub fn set_peer_params(&mut self, p: &TransportParams)

Applies the peer’s transport parameters.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn open(&mut self, bidi: bool) -> Result<u64, StreamError>

Opens a locally initiated stream.

pub fn on_stream( &mut self, id: u64, off: u64, data: &[u8], fin: bool, ) -> Result<(), TransportError>

pub fn on_reset( &mut self, id: u64, code: u64, final_size: u64, ) -> Result<(), TransportError>

pub fn on_stop_sending( &mut self, id: u64, code: u64, ) -> Result<(), TransportError>

pub fn on_max_stream_data( &mut self, id: u64, max: u64, ) -> Result<(), TransportError>

pub fn on_stream_data_blocked(&mut self, id: u64) -> Result<(), TransportError>

pub fn on_max_data(&mut self, max: u64)

pub fn on_max_streams(&mut self, bidi: bool, max: u64)

pub fn on_streams_blocked(&mut self, bidi: bool, limit: u64)

pub fn write( &mut self, id: u64, data: &[u8], fin: bool, ) -> Result<usize, StreamError>

Buffers data for sending; returns how many bytes were accepted.

pub fn read( &mut self, id: u64, out: &mut [u8], ) -> Result<(usize, bool), StreamError>

Reads in-order data; returns (bytes, fin reached).

pub fn reset(&mut self, id: u64, code: u64) -> Result<(), StreamError>

Abandons sending with RESET_STREAM.

pub fn stop(&mut self, id: u64, code: u64) -> Result<(), StreamError>

Asks the peer to stop sending with STOP_SENDING; buffered data is discarded.

pub fn has_pending_data(&self) -> bool

pub fn write_frames( &mut self, out: &mut Vec<u8>, limit: usize, sent: &mut Vec<SentFrame>, )

Writes STREAM frames into out while at least min_room bytes are left before limit; records (id, off, len, fin) in sent.

pub fn write_control( &mut self, c: Control, out: &mut Vec<u8>, limit: usize, ) -> Option<bool>

Writes one control frame if it fits; returns false when it does not.

pub fn on_stream_acked(&mut self, id: u64, off: u64, len: u64, fin: bool)

pub fn on_stream_lost(&mut self, id: u64, off: u64, len: u64, fin: bool)

pub fn on_reset_acked(&mut self, id: u64)

pub fn contains(&self, id: u64) -> bool

True if the stream exists.

pub fn unacked(&self, id: u64) -> Option<u64>

Bytes buffered and not yet acknowledged on a send stream.

pub fn writable(&self, id: u64) -> Option<u64>

How many more bytes write would accept now.