Struct Message 

pub struct Message {
    pub version: u16,
    pub id: MessageId,
    pub command: Command,
}

Fields

version: u16

id: MessageId

command: Command

Implementations

impl Message

pub fn new(command: Command) -> Self

New

pub fn make_response(&self, command: Command) -> Self

pub fn serialize(&self) -> Result<Vec<u8>, MessageError>

Serialize message into a Vec to be sent Message is serialized into: [10 bytes header (version 2, id 4, payload size 4)][payload]

pub async fn send( &self, stream: &mut OwnedWriteHalf, ) -> Result<(), MessageError>

Send this message to a TcpStream (its owned write half)

pub async fn from_stream( stream: &mut OwnedReadHalf, ) -> Result<Self, MessageError>

Read a message from a TcpStream (its owned read half)

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.