Trait rxrust::subscription::Subscription

pub trait Subscription {
    // Required method
    fn unsubscribe(self);

    // Provided methods
    fn is_closed(&self) -> bool { ... }
    fn unsubscribe_when_dropped(self) -> SubscriptionGuard<Self>
       where Self: Sized { ... }
}

Subscription returns from Observable.subscribe(Subscriber) to allow unsubscribing.

Required Methods

fn unsubscribe(self)

This allows deregistering an stream before it has finished receiving all events (i.e. before onCompleted is called).

Provided Methods

fn is_closed(&self) -> bool

detect if the subscription already be 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.

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 ()

fn unsubscribe(self)

fn is_closed(&self) -> bool

Implementors

impl Subscription for BoxSubscriptionThreads

impl Subscription for MultiSubscriptionThreads

impl<'a> Subscription for BoxSubscription<'a>

impl<'a> Subscription for MultiSubscription<'a>

impl<'a, Item, Err> Subscription for MutRefErrSubject<'a, Item, Err>

impl<'a, Item, Err> Subscription for MutRefItemErrSubject<'a, Item, Err>

impl<'a, Item, Err> Subscription for MutRefItemSubject<'a, Item, Err>

impl<'a, Item, Err> Subscription for Subject<'a, Item, Err>

impl<C, F, U> Subscription for FinalizerSubscription<U, C>where U: Subscription, C: RcDerefMut<Target = Option<F>>, F: FnOnce(),

impl<Item, Err> Subscription for SubjectThreads<Item, Err>

impl<Item, Subject> Subscription for BehaviorSubject<Item, Subject>where Subject: Subscription,

impl<O> Subscription for Subscriber<O>

impl<O> Subscription for SubscriberThreads<O>

impl<T, S> Subscription for Twhere T: RcDerefMut<Target = Option<S>> + RcDeref<Target = Option<S>>, S: Subscription,

impl<T: 'static> Subscription for TaskHandle<NormalReturn<T>>

impl<T: Subscription + 'static> Subscription for TaskHandle<SubscribeReturn<T>>

impl<U, Subject> Subscription for RefCountSubscription<Subject, U>where Subject: Subscription + SubjectSize, U: Subscription,

impl<U: Subscription, H: Subscription> Subscription for ZipSubscription<H, U>