Enum MessagePayload 

pub enum MessagePayload {
    Local(Box<dyn Any + Send>),
    Serialized(Bytes),
}

The payload carried alongside an Envelope.

Local is used for same-core delivery with zero serialization. Serialized carries an opaque byte buffer for cross-core or cross-engine delivery.

Variants

Local(Box<dyn Any + Send>)

Serialized(Bytes)

Implementations

impl MessagePayload

pub fn local<M: Send + 'static>(msg: M) -> Self

pub fn serialized(bytes: impl Into<Bytes>) -> Self

pub fn downcast_owned<T: Send + 'static>(self) -> Option<T>

Consume the payload and extract an owned value of type T.

Returns None if the payload is Serialized or the stored value is not of type T.

pub fn extract<M: Message>(&self) -> Result<&M, PayloadError>

Typed access to a Local payload. Returns PayloadError::TypeMismatch if the stored value is not of type M, or PayloadError::WrongVariant if the payload is Serialized.

pub fn downcast_ref<M: 'static>(&self) -> Option<&M>

pub fn as_serialized(&self) -> Option<&Bytes>

pub fn into_serialized(self) -> Option<Bytes>

pub fn payload_len(&self) -> u32

Meaningful only for Serialized; returns 0 for Local.

Trait Implementations

impl Debug for MessagePayload

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

Formats the value using the given formatter.