Trait Subscription 

pub trait Subscription {
    // Required methods
    fn unsubscribe(self);
    fn is_closed(&self) -> bool;

    // Provided method
    fn unsubscribe_when_dropped(self) -> SubscriptionGuard<Self>
       where Self: Sized { ... }
}

Subscription trait for managing observable subscriptions

Provides methods to cancel a subscription and check its status. Uses move semantics for unsubscribe to match the terminal nature of the operation, consistent with Observer’s error(self) and complete(self) methods.

Required Methods

fn unsubscribe(self)

Cancel the subscription (terminal operation, consumes self)

fn is_closed(&self) -> bool

Check if the subscription is closed (completed or unsubscribed)

Provided Methods

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.

Attention: If you don’t assign the return value to a variable, unsubscribe() is called immediately, which is probably not what you want!

Implementations on Foreign Types

impl Subscription for ()

Unit subscription - always closed, does nothing

fn unsubscribe(self)

fn is_closed(&self) -> bool

impl<P: Subscription> Subscription for Option<P>

Option subscription - None is closed, Some delegates to inner

fn unsubscribe(self)

fn is_closed(&self) -> bool

Implementors

impl Subscription for TaskHandle

impl Subscription for BoxedSubscription

impl Subscription for BoxedSubscriptionSend

impl<A, B> Subscription for EitherSubscription<A, B>

where A: Subscription, B: Subscription,

impl<A, B> Subscription for MutArc<EitherSubscription<A, B>>

where A: Subscription, B: Subscription,

impl<A, B> Subscription for MutRc<EitherSubscription<A, B>>

where A: Subscription, B: Subscription,

impl<F> Subscription for ClosureSubscription<F>

where F: FnOnce(),

impl<Item, O, Param, BoxedSub> Subscription for ThrottleState<Item, O, Param, BoxedSub>

where Param: ThrottleParam<Item>, BoxedSub: Subscription,

impl<P, InnerSub, ConnPtr, O> Subscription for RefCountSubscription<P, InnerSub, ConnPtr>

where P: RcDeref<Target = Subscribers<O>>, InnerSub: Subscription, ConnPtr: Subscription,

impl<P, O, Sch, Cell> Subscription for SubjectSubscription<P, Sch, Cell>

where P: RcDerefMut<Target = Subscribers<O>>, Sch: Scheduler<Task<RemoveState<P>>>, Cell: SharedCell<SubscriptionState>,

impl<P: Subscription> Subscription for MutArc<Option<P>>

impl<P: Subscription> Subscription for MutRc<Option<P>>

impl<S, Inner: Subscription + Send> Subscription for SharedCtx<Inner, S>

where S: Clone + Default,

impl<S, Inner: Subscription> Subscription for LocalCtx<Inner, S>

where S: Clone + Default,

impl<U1, U2> Subscription for TupleSubscription<U1, U2>

where U1: Subscription, U2: Subscription,

impl<U, H> Subscription for SourceWithHandle<U, H>

where U: Subscription, H: Subscription,

impl<U, P, F> Subscription for FinalizeSubscription<U, P>

where U: Subscription, P: RcDerefMut<Target = Option<F>>, F: FnOnce(),

impl<U, S, H> Subscription for SourceWithDynamicSubs<U, S>

where U: Subscription, S: RcDerefMut<Target = DynamicSubscriptions<H>>, H: Subscription,