Struct rxrust::scheduler::TaskHandle

pub struct TaskHandle<T>(_);

Implementations

impl<T> TaskHandle<T>

pub fn value_handle(v: T) -> Self

Trait Implementations

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

fn unsubscribe(self)

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

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.

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

fn unsubscribe(self)

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

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.