Struct ColdObservable 

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

A sequence of recorded notifications at times relative to each subscription (ColdObservable<T>, ITestableObservable<T>).

Implementations

impl<T: Clone + 'static> ColdObservable<T>

pub fn subscriptions(&self) -> Vec<Subscription>

The subscriptions made to the sequence (Subscriptions).

pub fn messages(&self) -> Vec<Recorded<Notification<T>>>

The notifications of the sequence (Messages).

pub fn as_observable(self: &Rc<Self>) -> Rc<dyn IObservable<T>>

The sequence as the handle operators take.

Trait Implementations

impl<T: Clone + 'static> IObservable<T> for ColdObservable<T>

fn subscribe(&self, observer: Rc<dyn IObserver<T>>) -> Rc<dyn IDisposable>

Subscribes observer; disposing the returned handle unsubscribes it.