Struct BoxedSubscriptionSend 

pub struct BoxedSubscriptionSend(/* private fields */);

A boxed subscription for shared (multi-threaded) contexts.

This allows storing heterogeneous subscriptions in collections across thread boundaries.

Why 'static?

Similar to BoxedSubscription, shared subscriptions must be 'static to be truly independent control handles. In multi-threaded contexts, this is even more critical as valid lifetimes across threads are typically 'static (required for Send in many cases, though scoped threads exist, rxRust targets general async/sync usage).

Examples

use rxrust::prelude::*;

// Create a thread-safe boxed subscription
let sub = BoxedSubscriptionSend::new(());

Implementations

impl BoxedSubscriptionSend

pub fn new(subscription: impl Subscription + Send + 'static) -> Self

Create a new thread-safe boxed subscription from any Send subscription type.

Trait Implementations

impl Subscription for BoxedSubscriptionSend

fn unsubscribe(self)

Cancel the subscription (terminal operation, consumes self)

fn is_closed(&self) -> bool

Check if the subscription is closed (completed or unsubscribed)

fn unsubscribe_when_dropped(self) -> SubscriptionGuard<Self>

where Self: Sized,

Activates “RAII” behavior for this subscription. That means unsubscribe() will be called automatically as soon as the returned value goes out of scope.