Struct StreamHeader 

pub struct StreamHeader {
    pub stream_id: u16,
    pub flags: StreamFlags,
    pub reserved: u8,
    pub length: u32,
}

Stream header for multiplexing

Format (8 bytes):

• stream_id: u16 (0 = control, 1-65535 = data streams)
• flags: u8 (FIN=1, RST=2, ACK=4, SYN=8)
• reserved: u8
• length: u32 (payload length, big-endian)

Fields

stream_id: u16

Stream ID (0 = control, 1-65535 = data streams)

flags: StreamFlags

Flags: FIN=1, RST=2, ACK=4, SYN=8

reserved: u8

Reserved for future use

length: u32

Payload length

Implementations

impl StreamHeader

pub const CONTROL_STREAM: u16 = 0

Control stream ID

pub const MAX_STREAM_ID: u16 = 65535

Maximum stream ID

pub fn new(stream_id: u16, flags: StreamFlags, length: u32) -> Self

Create a new stream header

pub fn data(stream_id: u16, length: u32) -> Self

Create a data header

pub fn syn(stream_id: u16) -> Self

Create a SYN header (open stream)

pub fn fin(stream_id: u16) -> Self

Create a FIN header (close stream)

pub fn rst(stream_id: u16) -> Self

Create a RST header (reset stream)

pub fn ack(stream_id: u16) -> Self

Create an ACK header

pub fn is_control(&self) -> bool

Check if this is a control stream message

pub fn encode(&self, dst: &mut BytesMut)

Encode header to bytes

pub fn to_bytes(&self) -> Bytes

Encode header to a new BytesMut

pub fn decode(src: &[u8]) -> Option<Self>

Decode header from bytes

pub fn decode_from(src: &mut BytesMut) -> Option<Self>

Decode header from BytesMut, advancing the buffer

pub fn frame_size(&self) -> usize

Total frame size (header + payload)

Trait Implementations

impl Clone for StreamHeader

fn clone(&self) -> StreamHeader

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for StreamHeader

impl Debug for StreamHeader

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

Formats the value using the given formatter.

impl Eq for StreamHeader

impl PartialEq for StreamHeader

fn eq(&self, other: &StreamHeader) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for StreamHeader