Struct SingleSubscriberObservableBase 

pub struct SingleSubscriberObservableBase<T> { /* private fields */ }

The base of observables that accept exactly one subscriber and hand themselves out as the subscription.

The observable embeds this state, implements IObservable by calling subscribe and IDisposable by calling dispose, passing what has to happen when the subscription starts and ends.

Implementations

impl<T> SingleSubscriberObservableBase<T>

pub fn new() -> Self

pub fn subscribe( &self, observer: Rc<dyn IObserver<T>>, subscribed: impl FnOnce(), )

Registers the observer. subscribed runs once it is registered, unless the observable has already failed or completed, in which case the observer is told so instead.

Panics when there already is a subscriber.

pub fn dispose(&self, unsubscribed: impl FnOnce())

Ends the subscription: runs unsubscribed and forgets the observer.

pub fn has_observer(&self) -> bool

Whether an observer is currently subscribed.

pub fn publish_next(&self, value: T)

pub fn publish_completed(&self, unsubscribed: impl FnOnce())

pub fn publish_error(&self, error: ObservableError, unsubscribed: impl FnOnce())

Trait Implementations

impl<T> Default for SingleSubscriberObservableBase<T>

fn default() -> Self

Returns the “default value” for a type.