Struct MessageHeader

pub struct MessageHeader {
    pub length: u32,
    pub stream_id: u32,
    pub type_: u8,
    pub flags: u8,
}

Message header of ttrpc.

Fields

length: u32

stream_id: u32

type_: u8

flags: u8

Implementations

impl MessageHeader

pub fn new_request(stream_id: u32, len: u32) -> Self

Creates a request MessageHeader from stream_id and len.

Use the default message type MESSAGE_TYPE_REQUEST, and default flags 0.

pub fn new_response(stream_id: u32, len: u32) -> Self

Creates a response MessageHeader from stream_id and len.

Use the MESSAGE_TYPE_RESPONSE message type, and default flags 0.

pub fn new_data(stream_id: u32, len: u32) -> Self

Creates a data MessageHeader from stream_id and len.

Use the MESSAGE_TYPE_DATA message type, and default flags 0.

pub fn set_stream_id(&mut self, stream_id: u32)

Set the stream_id of message using the given value.

pub fn set_flags(&mut self, flags: u8)

Set the flags of message using the given flags.

pub fn add_flags(&mut self, flags: u8)

Add a new flags to the message.

impl MessageHeader

pub async fn write_to(&self, writer: impl AsyncWriteExt + Unpin) -> Result<()>

Encodes a MessageHeader to writer.

pub async fn read_from( reader: impl AsyncReadExt + Unpin, ) -> Result<MessageHeader>

Decodes a MessageHeader from reader.

Trait Implementations

impl Clone for MessageHeader

fn clone(&self) -> MessageHeader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageHeader

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

Formats the value using the given formatter.

impl Default for MessageHeader

fn default() -> MessageHeader

Returns the “default value” for a type.

impl From<MessageHeader> for Vec<u8>

fn from(mh: MessageHeader) -> Self

Converts to this type from the input type.

impl<T> From<T> for MessageHeader

where T: AsRef<[u8]>,

fn from(buf: T) -> Self

Converts to this type from the input type.

impl PartialEq for MessageHeader

fn eq(&self, other: &MessageHeader) -> 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 Copy for MessageHeader

impl Eq for MessageHeader

impl StructuralPartialEq for MessageHeader