Struct Message 

pub struct Message {
    pub topic: String,
    pub payload: Vec<u8>,
}

A message that arrived on a subscribed topic.

Every link that can deliver hands back the same shape, so a node reads a command the same way whether it came over MQTT, CoAP, Zenoh, or the in-process broker used in tests.

Fields

topic: String

The topic the message was published to.

payload: Vec<u8>

The raw payload bytes.

Implementations

impl Message

pub fn new(topic: impl Into<String>, payload: impl Into<Vec<u8>>) -> Self

Creates a message from a topic and a payload.

Arguments

• topic - the topic the message was published to.
• payload - the raw payload bytes.

Returns

The message.

pub fn text(&self) -> Result<&str>

Reads the payload as text.

Most readings and commands on a topic are words or a number written out, and this is the accessor for them; a payload that is a codec’s bytes goes through the codec instead.

Returns

The payload as a string slice.

Errors

Returns Error::Codec if the payload is not UTF-8 text.

pub fn number(&self) -> Result<f64>

Reads the payload as a number written out as text, such as 21.5.

Returns

The number.

Errors

Returns Error::Codec if the payload is not UTF-8 text or the text is not a number.

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.

impl Eq for Message

impl PartialEq for Message

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Message