Struct ttrpc::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 copy 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 MessageHeaderwhere T: AsRef<[u8]>,

fn from(buf: T) -> Self

Converts to this type from the input type.

impl PartialEq<MessageHeader> for MessageHeader

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

This method tests for self and other values to be equal, and is used by ==.

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

This method 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 StructuralEq for MessageHeader

impl StructuralPartialEq for MessageHeader