Struct Envelope 

pub struct Envelope {
    pub value: Arc<dyn Any + Send + Sync>,
    /* private fields */
}

A type-erased envelope that can carry any Send + Sync value.

Fields

value: Arc<dyn Any + Send + Sync>

Implementations

impl Envelope

pub fn new<T: 'static + Send + Sync>( value: T, msg_id: u64, tracker: Option<Arc<CompletionTracker>>, ) -> Self

Create a new envelope from any Send + Sync value.

pub fn with_origin<T: 'static + Send + Sync>( value: T, msg_id: u64, tracker: Option<Arc<CompletionTracker>>, origin: u64, ) -> Self

Create a new envelope with a specific origin stream ID.

pub fn from_any( value: Arc<dyn Any + Send + Sync>, type_id: TypeId, msg_id: u64, tracker: Option<Arc<CompletionTracker>>, ) -> Self

Create an envelope from an already type-erased value with known TypeId.

This is useful when you have a value that’s already been type-erased (e.g., from a registry or dynamic dispatch) but want to preserve its original type for downstream filtering.

pub fn from_any_with_origin( value: Arc<dyn Any + Send + Sync>, type_id: TypeId, msg_id: u64, tracker: Option<Arc<CompletionTracker>>, origin: u64, ) -> Self

Create an envelope from type-erased value with a specific origin.

pub fn type_id(&self) -> TypeId

Get the TypeId of the contained value.

pub fn msg_id(&self) -> u64

Get the message ID.

pub fn tracker(&self) -> Option<Arc<CompletionTracker>>

Get the completion tracker if present.

pub fn origin(&self) -> u64

Get the origin stream ID.

pub fn with_new_origin(&self, origin: u64) -> Self

Create a copy of this envelope with a new origin.

pub fn without_tracker(&self) -> Self

Create a copy of this envelope without a tracker. Used when forwarding events - the target stream has its own handlers.

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

Attempt to downcast to a concrete type reference.

pub fn downcast<T: 'static + Send + Sync>(&self) -> Option<Arc<T>>

Attempt to get an Arc of the concrete type.

pub fn is<T: 'static>(&self) -> bool

Check if the envelope contains a value of type T.

Trait Implementations

impl Clone for Envelope

fn clone(&self) -> Envelope

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Envelope

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

Formats the value using the given formatter.