Module rxrust::ops[][src]

Modules

Type Definitions

Holds intermediate computations of accumulated values for [Observable@Average] operator, as nominator and denominator respectively.

Realised as chained composition of scan->last->map operators.

Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then merging those resulting Observables and emitting the results of this merger.

Realised as chained composition of scan->last->map operators.