Struct RelayReceiver 

pub struct RelayReceiver { /* private fields */ }

A receiver handle for subscribing to channel messages.

This type is Clone but does not keep the channel alive. When the RelaySender is dropped, all subscriptions will return None.

Implementations

impl RelayReceiver

pub fn subscribe<T: 'static + Send + Sync>(&self) -> Subscription<T>

Subscribe to messages of type T.

Returns a Subscription that yields messages until the channel closes.

pub fn subscribe_all(&self) -> Receiver<Envelope>

Subscribe to all messages regardless of type.

Returns raw Envelopes containing type-erased values.

pub fn subscribe_tracked<T: 'static + Send + Sync>( &self, ) -> (Subscription<T>, Arc<AtomicUsize>)

Subscribe with completion tracking (for internal use). Returns (subscription, handler_count). The subscription is immediately ready to receive messages (channel is created and buffering).

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 sink<T, F, R>(&self, f: F)

where T: 'static + Send + Sync, F: Fn(&T) -> R + Send + Sync + 'static, R: IntoResult + 'static,

Attach a handler that consumes messages of type T.

The sender will wait for this handler to complete before send() returns. Errors and panics are propagated back to the sender via the completion tracker.

pub fn tap<T, F, R>(&self, f: F)

where T: 'static + Send + Sync, F: Fn(&T) -> R + Send + Sync + 'static, R: IntoResult + 'static,

Attach an observer that sees messages of type T without consuming them.

Similar to sink() but doesn’t prevent other handlers from receiving the message. The sender will wait for this handler to complete before send() returns.

pub fn within<F, Fut>(&self, f: F)

where F: FnOnce() -> Fut + Send + 'static, Fut: Future<Output = ()> + Send,

Spawn a custom async task with panic catching.

Unlike sink/tap, this does NOT participate in completion tracking. Panics are caught but not propagated (just logged).

Trait Implementations

impl Clone for RelayReceiver

fn clone(&self) -> RelayReceiver

Returns a duplicate of the value.

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

Performs copy-assignment from source.