Struct PubMessage 

pub struct PubMessage<A>
where
    A: Address,
{ /* private fields */ }

A message received from a publisher. Includes the source, topic, and payload.

Implementations

impl<A> PubMessage<A>

where A: Address,

pub fn new(source: A, topic: String, payload: Bytes) -> PubMessage<A>

pub fn source(&self) -> &A

pub fn topic(&self) -> &str

pub fn payload(&self) -> &Bytes

pub fn into_payload(self) -> Bytes

Trait Implementations

impl<A> Clone for PubMessage<A>

where A: Clone + Address,

fn clone(&self) -> PubMessage<A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A> Debug for PubMessage<A>

where A: Address,

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

Formats the value using the given formatter.