Type Definition medea_reactive::Progressable[−][src]

type Progressable<D> = ObservableField<D, SubStore<D>>;

ObservableField that allows to subscribe to all changes (ObservableField::subscribe) and to concrete changes (ObservableField::when and ObservableField::when_eq).

Can recognise when all updates was processed by subscribers.

Implementations

impl<D: 'static> Progressable<D>[src]

pub fn new(data: D) -> Self[src]

Returns new ObservableField with subscribable mutations.

Also, you can wait for all updates processing by awaiting on ObservableField::when_all_processed().

impl<D> Progressable<D> where
    D: Clone + 'static, [src]

pub fn subscribe(&self) -> LocalBoxStream<'static, Guarded<D>>[src]

Returns Stream into which underlying data updates (wrapped in the progressable::Guarded) will be emitted.

pub fn when_all_processed(&self) -> Processed<'static>ⓘ

Notable traits for Processed<'a, T>

impl<'a, T> Future for Processed<'a, T> type Output = T;
[src]

Returns Future resolving when all data updates will be processed by subscribers.