Struct Message 

pub struct Message<T: Send + Sync> {
    pub token: Token,
    pub meta: MessageMeta,
    pub payload: Arc<T>,
}

Envelope carrying payload plus token/metadata.

Payload T must be Send + Sync to be safely shared in async/concurrent runtimes.

use daedalus_core::clock::Tick;
use daedalus_core::messages::{Message, MessageMeta, Sequence, Token};

let meta = MessageMeta::new(Tick::new(1), Sequence::new(0));
let msg = Message::new(Token::new(7), meta, "payload");
assert_eq!(msg.payload.as_ref(), &"payload");

Fields

token: Token

meta: MessageMeta

payload: Arc<T>

Implementations

impl<T: Send + Sync> Message<T>

pub fn new(token: Token, meta: MessageMeta, payload: T) -> Self

pub fn map<U: Send + Sync>(self, f: impl FnOnce(Arc<T>) -> U) -> Message<U>

Map payload while preserving token/metadata.

Trait Implementations

impl<T: Clone + Send + Sync> Clone for Message<T>

fn clone(&self) -> Message<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Send + Sync> Debug for Message<T>

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

Formats the value using the given formatter.

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

where T: Deserialize<'de> + Send + Sync,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> Serialize for Message<T>

where T: Serialize + Send + Sync,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.