Struct 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

Creates a new Msg with the given data.

use simple_pub_sub_message::message::Msg;
use simple_pub_sub_message::PktType;
let msg = Msg::new(PktType::PUBLISH, "Test".to_string(), Some(b"The message".to_vec()));

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

adds the given channel to the message.

use simple_pub_sub_message::message::Msg;
use simple_pub_sub_message::PktType;
use tokio::sync::broadcast::Sender;
let mut msg = Msg::new(PktType::PUBLISH, "Test".to_string(), Some(b"The message".to_vec()));
let chan: tokio::sync::broadcast::Sender<Msg> =
  tokio::sync::broadcast::Sender::new(1);
msg.channel(chan)

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

returns the client id for the message.

use simple_pub_sub_message::message::Msg;
use simple_pub_sub_message::PktType;
use uuid;
let mut msg = Msg::new(PktType::PUBLISH, "Test".to_string(), Some(b"The message".to_vec()));
let client_id = uuid::Uuid::new_v4().to_string();
msg.client_id(client_id)

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

generates the response Msg with the given data.

use simple_pub_sub_message::message::Msg;
use simple_pub_sub_message::PktType;
let mut msg = Msg::new(PktType::PUBLISH, "Test".to_string(), Some(b"The message".to_vec()));
let response_msg = msg.response_msg(vec![]);

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

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

 use simple_pub_sub_message::message::Msg;
 use simple_pub_sub_message::PktType;
 let mut msg = Msg::new(PktType::PUBLISH, "Test".to_string(), Some(b"The message".to_vec()));
 let bytes = msg.bytes();

Trait Implementations

impl Clone for Msg

fn clone(&self) -> Msg

Returns a duplicate 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<(), Error>

Formats the value using the given formatter.

impl PartialEq for Msg

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl TryFrom<&[u8]> for Msg

fn try_from(bytes: &[u8]) -> Result<Msg, Error>

Parses a Msg from a Vec<u8>.

use simple_pub_sub_message::message::Msg;
let buf = [15, 0, 1, 2, 3, 0, 12, 0, 97, 98,
  99, 116, 101, 115, 116, 32, 109, 101, 115,
  115, 97, 103, 101];
let msg = Msg::try_from(buf.as_ref()).unwrap();
println!("{:?}", msg);

type Error = Error

The type returned in the event of a conversion error.

impl TryFrom<Vec<u8>> for Msg

fn try_from(bytes: Vec<u8>) -> Result<Msg, Error>

Parses a Msg from a Vec<u8>.

use simple_pub_sub_message::message::Msg;
let buf = vec![15, 0, 1, 2, 3, 0, 12, 0, 97, 98,
  99, 116, 101, 115, 116, 32, 109, 101, 115,
  115, 97, 103, 101];
let msg = Msg::try_from(buf).unwrap();

type Error = Error

The type returned in the event of a conversion error.