Struct pliantdb_local::core::circulate::Message[]

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

A PubSub message.

Fields

topic: String

The topic of the message.

payload: Vec<u8, Global>

The payload of the message.

Implementations

impl Message

pub fn new<S, P>(topic: S, payload: &P) -> Result<Message, Error> where
    S: Into<String>,
    P: Serialize

Creates a new message.

Errors

Returns an error if payload fails to serialize with serde_cbor.

pub fn payload<P>(&self) -> Result<P, Error> where
    P: for<'de> Deserialize<'de>, 

Deserialize the payload as P using CBOR.

Errors

Returns an error if payload fails to deserialize with serde_cbor.

Trait Implementations

impl Clone for Message

impl Debug for Message

impl<'de> Deserialize<'de> for Message

impl Serialize for Message

Auto Trait Implementations

impl RefUnwindSafe for Message

impl Send for Message

impl Sync for Message

impl Unpin for Message

impl UnwindSafe for Message

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Conv for T

impl<T> Conv for T

impl<T> DeserializeOwned for T where
    T: for<'de> Deserialize<'de>, 
[src]

impl<T> FmtForward for T

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> Pipe for T where
    T: ?Sized

impl<T> Pipe for T

impl<T> PipeAsRef for T

impl<T> PipeBorrow for T

impl<T> PipeDeref for T

impl<T> PipeRef for T

impl<T> Pointable for T

type Init = T

The type for initializers.

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T> Tap for T

impl<T> Tap for T

impl<T, U> TapAsRef<U> for T where
    U: ?Sized

impl<T, U> TapBorrow<U> for T where
    U: ?Sized

impl<T> TapDeref for T

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T> TryConv for T

impl<T> TryConv for T

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,