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.