Struct RelaySender 

pub struct RelaySender { /* private fields */ }

The single owner of a relay channel.

This type is intentionally not Clone. There is exactly one owner of a channel, and when this owner is dropped, the channel closes.

Use weak() to create WeakSender handles that can send messages without keeping the channel alive.

Implementations

impl RelaySender

pub async fn send<T: 'static + Send + Sync>( &self, value: T, ) -> Result<(), SendError>

Send a typed message to all subscribers.

pub async fn send_any( &self, value: Arc<dyn Any + Send + Sync>, type_id: TypeId, ) -> Result<(), SendError>

Send a type-erased message.

pub async fn send_any_with_origin( &self, value: Arc<dyn Any + Send + Sync>, type_id: TypeId, origin: u64, ) -> Result<(), SendError>

Send a type-erased message with a specific origin (for echo prevention).

pub async fn send_envelope(&self, envelope: Envelope) -> Result<(), SendError>

Send a pre-constructed envelope. Used for advanced scenarios like forwarding.

pub fn weak(&self) -> WeakSender

Create a weak sender handle.

Weak senders can send messages but don’t keep the channel alive. Use this for background tasks that should exit when the owner drops.

pub fn is_closed(&self) -> bool

Check if the channel is closed.

pub fn id(&self) -> u64

Get the unique ID of this channel.

pub fn handler_count(&self) -> usize

Get the current handler count for this relay.

pub fn close(&self)

Close the channel explicitly. This has the same effect as dropping the RelaySender.

Trait Implementations

impl Drop for RelaySender

fn drop(&mut self)

Executes the destructor for this type.