Type Alias AggregateChangeSets 

pub type AggregateChangeSets<T> = Rc<dyn IObservable<Rc<dyn IAggregateChangeSet<T>>>>;

A sequence of aggregate change sets (IObservable<IAggregateChangeSet<T>>).

Aliased Type

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

Trait Implementations

impl<T: 'static> AggregateChangeSetEx<T> for AggregateChangeSets<T>

fn avg<V: AggregateValue>( &self, value_selector: impl Fn(&T) -> V + 'static, ) -> Rc<dyn IObservable<<V::Number as AggregateNumber>::Average>>

The average of the values of the items after each change set, zero when there are none (Avg(Func<T, TValue>)).

fn avg_with<V: AggregateValue>( &self, value_selector: impl Fn(&T) -> V + 'static, empty_value: V::Number, ) -> Rc<dyn IObservable<<V::Number as AggregateNumber>::Average>>

avg with the value when there are no items (Avg(Func<T, TValue>, TValue emptyValue)).

fn count_aggregate(&self) -> Rc<dyn IObservable<usize>>

The count of the items after each change set (Count<TObject>()).

fn std_dev<V: StdDevValue>( &self, value_selector: impl Fn(&T) -> V + 'static, fallback_value: V, ) -> Rc<dyn IObservable<f64>>

The sample standard deviation of the values of the items after each change set, fallback_value for fewer than two items (StdDev(Func<T, TValue>, TValue fallbackValue)).

fn sum_aggregate<V: AggregateValue>( &self, value_selector: impl Fn(&T) -> V + 'static, ) -> Rc<dyn IObservable<V::Number>>

The sum of the values of the items after each change set (Sum(Func<T, TValue>)).