Struct simple_pub_sub::message::Msg

pub struct Msg {
    pub header: Header,
    pub topic: String,
    pub message: Vec<u8>,
    pub channel: Option<Sender<Msg>>,
    pub client_id: Option<String>,
}

structure containing the complete information about a message.

Fields

header: Header

Header: the header of the message.

topic: String

The topic for the message.

message: Vec<u8>

the actual message, bytes.

channel: Option<Sender<Msg>>

tokio::broadcast::sync::Sender the channel for passing the messages across.

client_id: Option<String>

client_id: to identify each socket connection/client.

Implementations

impl Msg

pub fn new(pkt_type: PktType, topic: String, message: Option<Vec<u8>>) -> Msg

pub fn channel(&mut self, chan: Sender<Msg>)

adds the given channel to the message.

pub fn client_id(&mut self, client_id: String)

pub fn response_msg(&self, _message: Vec<u8>) -> Result<Msg, String>

generates the response Msg with the given data.

pub fn bytes(&self) -> Vec<u8>

returns bytes for the Msg that can be sent to the stream.

Trait Implementations

impl Clone for Msg

fn clone(&self) -> Msg

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Msg

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

Formats the value using the given formatter.