Trait rxrust::subscription::SubscriptionLike

pub trait SubscriptionLike {
    fn unsubscribe(&mut self);
    fn is_closed(&self) -> bool;
    fn inner_addr(&self) -> *const ();
}

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

Required methods

fn unsubscribe(&mut self)

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

fn is_closed(&self) -> bool

fn inner_addr(&self) -> *const ()

Loading content...

Implementations on Foreign Types

impl<'a> SubscriptionLike for Box<dyn SubscriptionLike + 'a>

fn unsubscribe(&mut self)

fn is_closed(&self) -> bool

fn inner_addr(&self) -> *const ()

impl SubscriptionLike for Box<dyn SubscriptionLike + Send + Sync>

fn unsubscribe(&mut self)

fn is_closed(&self) -> bool

fn inner_addr(&self) -> *const ()

Loading content...

Implementors

impl SubscriptionLike for LocalSubscription

fn unsubscribe(&mut self)

fn is_closed(&self) -> bool

fn inner_addr(&self) -> *const ()

impl SubscriptionLike for SharedSubscription

fn unsubscribe(&mut self)

fn is_closed(&self) -> bool

fn inner_addr(&self) -> *const ()

impl<C> SubscriptionLike for RefCountSubscription<LocalSubscription, C> where
    C: SubscriptionLike, 

fn unsubscribe(&mut self)

fn is_closed(&self) -> bool

fn inner_addr(&self) -> *const ()

impl<C> SubscriptionLike for RefCountSubscription<SharedSubscription, C> where
    C: SubscriptionLike, 

fn unsubscribe(&mut self)

fn is_closed(&self) -> bool

fn inner_addr(&self) -> *const ()

impl<O, U> SubscriptionLike for Subscriber<O, U> where
    U: SubscriptionLike, 

fn unsubscribe(&mut self)

fn is_closed(&self) -> bool

fn inner_addr(&self) -> *const ()

Loading content...