Struct DispatchMessage 

pub struct DispatchMessage<T> { /* private fields */ }

A live message carrying an owner-thread callback context through a send-safe channel.

Conversion with From<T> creates independent ingress without capturing a callback root. External-thread sends and sends without an active root are also independent ingress. Rooted messages must be processed on their owner’s thread. Foreign-thread destruction releases the root at the next owner channel boundary, callback quiescence check, or dispatcher teardown.

Implementations

impl<T> DispatchMessage<T>

pub fn new(message: T, owner: ThreadId) -> Self

Wraps a message, capturing callback ancestry only when called on owner.

owner is the runtime thread that processes messages from this channel.

Panics

Panics if the owner exhausts its channel context IDs.

pub fn dispatch<R>(self, run: impl FnOnce(T) -> R) -> R

Processes the message under its originating callback context.

Panics

Panics if a rooted message is processed outside its owner’s thread.

pub fn is_rooted(&self) -> bool

Returns whether this message retains an originating callback root.

impl DispatchMessage<TradingCommandMessage>

pub fn dispatch_trading(self, before: impl FnMut(&TradingCommandMessage))

Dispatches the command and its deferred children under their captured callback roots.

Calls before immediately before each endpoint dispatch, including child commands.

Panics

Panics if:

• A rooted message is processed outside its owner thread.
• The observer or a command handler panics.

Trait Implementations

impl<T: Debug> Debug for DispatchMessage<T>

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

Formats the value using the given formatter.

impl<T: Display> Display for DispatchMessage<T>

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

Formats the value using the given formatter.

impl<T> Drop for DispatchMessage<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl<T> From<T> for DispatchMessage<T>

fn from(message: T) -> Self

Converts to this type from the input type.