Struct datastreamcorelib::pubsub::PubSubMessage

pub struct PubSubMessage {
    pub topic: String,
    pub dataparts: Vec<BytesMut>,
}

Raw PUB/SUB message

Fields

topic: String

dataparts: Vec<BytesMut>

Implementations

impl PubSubMessage

pub fn new(topic: String) -> Fallible<PubSubMessage>

Instantiate new PubSubDataMessage with given topic

Trait Implementations

impl Clone for PubSubMessage

fn clone(&self) -> PubSubMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PubSubMessage

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

Formats the value using the given formatter.

impl Default for PubSubMessage

fn default() -> PubSubMessage

Returns the "default value" for a type.

impl PubSubMessageMarker for PubSubMessage

impl<'_> TryFrom<&'_ PubSubDataMessage> for PubSubMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: &PubSubDataMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_> TryFrom<&'_ PubSubImageMessage> for PubSubMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: &PubSubImageMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_> TryFrom<&'_ PubSubMessage> for PubSubDataMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: &PubSubMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_> TryFrom<&'_ PubSubMessage> for PubSubImageMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: &PubSubMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_> TryFrom<&'_ PubSubMessage> for RawMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: &PubSubMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl<'_> TryFrom<&'_ RawMessage> for PubSubMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: &RawMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<PubSubDataMessage> for PubSubMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: PubSubDataMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<PubSubImageMessage> for PubSubMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: PubSubImageMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<PubSubMessage> for PubSubDataMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: PubSubMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<PubSubMessage> for PubSubImageMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: PubSubMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<PubSubMessage> for RawMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: PubSubMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<RawMessage> for PubSubMessage

type Error = Error

The type returned in the event of a conversion error.

fn try_from(rmsg: RawMessage) -> Result<Self, Self::Error>

Performs the conversion.

impl ZMQCodec for PubSubMessage

fn zmq_encode(&self) -> Fallible<Vec<Message>>

Encode the abtracted message into ZMQ message parts, ready for sending

fn zmq_decode(from: Vec<Message>) -> Fallible<Box<Self>>

Decode ZMQ message parts into a pointer to abstracted message

impl ZMQMessageMarker for PubSubMessage