Struct Frame 

pub struct Frame {
    pub message_type: MessageType,
    pub payload: Bytes,
}

A framed message with type and payload

Fields

message_type: MessageType

payload: Bytes

Implementations

impl Frame

pub fn request<M: Message>(msg: &M) -> Result<Self, FrameError>

Create a new request frame

pub fn response<M: Message>(msg: &M) -> Result<Self, FrameError>

Create a new response frame

pub fn error<M: Message>(msg: &M) -> Result<Self, FrameError>

Create a new error frame

pub fn stream_data<M: Message>(msg: &M) -> Result<Self, FrameError>

Create a new stream data frame

pub fn new<M: Message>( message_type: MessageType, msg: &M, ) -> Result<Self, FrameError>

Create a new frame with the given type and message

pub fn decode<M: Message + Default>(&self) -> Result<M, FrameError>

Decode the payload as a protobuf message

pub fn encode(&self) -> Bytes

Encode the frame to bytes for wire transmission

pub fn decode_from_bytes(bytes: Bytes) -> Result<Self, FrameError>

Decode a frame from bytes

Trait Implementations

impl Clone for Frame

fn clone(&self) -> Frame

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Frame

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

Formats the value using the given formatter.