Struct DispatchSender 

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

A message sender which preserves callback ancestry when bound to a live runtime.

Sends on the runtime owner thread capture its active root. Sends on other threads and sends without an active root are independent ingress. Conversion from a plain Tokio sender supports standalone clients whose receivers consume domain events directly, without callback tracking.

Implementations

impl<T> DispatchSender<T>

pub fn new(sender: UnboundedSender<DispatchMessage<T>>) -> Self

Binds a dispatch channel to the calling runtime thread.

pub fn send(&self, message: T) -> Result<(), SendError<DispatchMessage<T>>>

Sends a message, preserving the active owner-thread callback root.

Errors

Returns the undelivered envelope if the receiver is closed.

Panics

Panics if the owner exhausts its channel context IDs.

pub fn is_closed(&self) -> bool

Returns whether the receiver has closed.

pub fn same_channel(&self, other: &Self) -> bool

Returns whether both senders target the same channel.

Trait Implementations

impl<T> Clone for DispatchSender<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for DispatchSender<T>

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

Formats the value using the given formatter.

impl<T> From<UnboundedSender<T>> for DispatchSender<T>

fn from(sender: UnboundedSender<T>) -> Self

Converts to this type from the input type.