Struct rxrust::subscription::SubscriptionWrapper

pub struct SubscriptionWrapper<T: SubscriptionLike>(_);

Wrapper around a subscription which provides the unsubscribe_when_dropped() method.

Implementations

impl<T: SubscriptionLike> SubscriptionWrapper<T>

pub fn unsubscribe_when_dropped(self) -> SubscriptionGuard<T>

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!

pub fn into_inner(self) -> T

Consumes this wrapper and returns the underlying subscription.

Trait Implementations

impl<T: SubscriptionLike> SubscriptionLike for SubscriptionWrapper<T>

fn is_closed(&self) -> bool

fn unsubscribe(&mut self)

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