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 an error if the receiver is closed. The error contains the undelivered envelope.

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.