operators library

Extensions

AuditOperator on Observable<T>
BufferOperator on Observable<T>
CastOperator on Observable<T>
CatchErrorOperator on Observable<T>
CombineLatestOperator on Observable<Observable<T>>
ComposeOperator on Observable<T>
ConcatOperator on Observable<T>
CountOperator on Observable<T>
DebounceOperator on Observable<T>
DefaultIfEmptyOperator on Observable<T>
DelayOperator on Observable<T>
DematerializeOperator on Observable<Event<T>>
DistinctOperator on Observable<T>
DistinctUntilChangedOperator on Observable<T>
ExhaustAllOperator on Observable<Observable<T>>
ExhaustMapOperator on Observable<T>
FinalizeOperator on Observable<T>
FirstOperator on Observable<T>
FlatMapOperator on Observable<T>
FlattenObservable on Observable<Observable<T>>
FoldOperator on Observable<T>
IgnoreElementsOperator on Observable<T>
IsEmptyOperator on Observable<T>
LastOperator on Observable<T>
MapOperator on Observable<T>
MaterializeOperator on Observable<T>
MergeAllOperator on Observable<Observable<T>>
MergeMapOperator on Observable<T>
MulticastOperator on Observable<T>
ObserveOnOperator on Observable<T>
PairwiseOperator on Observable<T>
PublishOperator on Observable<T>
ReduceOperator on Observable<T>
RefCountOperator on ConnectableObservable<T>
RepeatOperator on Observable<T>
SampleOperator on Observable<T>
SingleOperator on Observable<T>
SkipOperator on Observable<T>
SkipUntilOperator on Observable<T>
SkipWhileOperator on Observable<T>
SwitchAllOperator on Observable<Observable<T>>
SwitchMapOperator on Observable<T>
TakeLastOperator on Observable<T>
TakeOperator on Observable<T>
TakeUntilOperator on Observable<T>
TakeWhileOperator on Observable<T>
TapOperator on Observable<T>
ThrottleOperator on Observable<T>
TimeoutOperator on Observable<T>
ToListOperator on Observable<T>
ToMapOperator on Observable<T>
ToSetOperator on Observable<T>
WhereOperator on Observable<T>
WhereTypeOperator on Observable<T>

Typedefs

Transformer<T, R> = Observable<R> Function(Observable<T> source)
Function that receives an Observable and returns another one, possibly changing its type.