Struct Message

pub struct Message {
    pub channel: u64,
    pub typ: u8,
    pub message: Vec<u8>,
}

A SMC message.

Fields

channel: u64

typ: u8

message: Vec<u8>

Implementations

impl Message

pub fn new(channel: u64, typ: u8, message: Vec<u8>) -> Message

Create a new message.

Examples found in repository

examples/send.rs (line 12)

async fn send() -> io::Result<()> {
    let stdout = io::stdout().lock().await;
    let mut writer = Writer::new(stdout);
    for i in 0..3 {
        let message = Message::new(i, 1, "hi".as_bytes().to_vec());
        print_msg(&message);
        writer.send(message).await?;
    }
    Ok(())
}

examples/tcp.rs (line 100)

async fn handle_outgoing(stream: TcpStream) -> Result<()> {
    let (mut reader, mut writer) = create_from_stream(stream);

    let hello_msg = Message::new(1, 1, "hi".as_bytes().to_vec());
    writer.send(hello_msg).await?;

    while let Some(msg) = reader.try_next().await? {
        eprintln!("received: {}", format_msg(&msg));
    }

    Ok(())
}

pub fn from_buf(buf: &[u8]) -> Result<Message, Error>

Decode a message from buf (bytes).

Note: buf has to have a valid length, and the length prefix has to be removed already.

pub fn encode(&self) -> Result<Vec<u8>, Error>

Encode a message body into a buffer.

The result can be sent directly over any medium. It is length-prefixed, so chunking should not be an issue.

Trait Implementations

impl Debug for Message

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

Formats the value using the given formatter.