Operators

Operators is way to modify observables and extend with some extra custom logic. More...

Modules
	Transforming Operators
	Transforming operators are operators that transform items provided by observable.
	Filtering Operators
	Filtering operators are operators that emit only part of items that satisfies some condition.
	Conditional Operators
	Conditional operators are operators that emit items based on some condition including condition of items from other observables.
	Combining Operators
	Combining operators are operators that combines emissions of multiple observables into same observable by some rule.
	Aggregate Operators
	Aggregate operators are operators on the entire sequence of items provided by observable.
	Utility Operators
	Utility operators are operators that provide some extra functionality without changing of original values, but changing of behaviour.
	Connectable Operators
	Connectable operators are operators that provide extra functionality for multicasting of controlling of subscription.
	Error handling Operators
	Error handling operators Operators that help to recover from error notifications from an Observable.
	Creational Operators
	Creational operators are operators that create new observable.

Functions
template<details::op_fn< SpecificObservable > OperatorFn>
auto	rpp::interface_observable< Type, SpecificObservable >::op (OperatorFn &&fn) const &
	The apply function to observable which returns observable of another type.

Detailed Description

Operators is way to modify observables and extend with some extra custom logic.

See also

https://reactivex.io/documentation/operators.html

Function Documentation

op()

template<constraint::decayed_type Type, typename SpecificObservable >

template<details::op_fn< SpecificObservable > OperatorFn>

auto rpp::interface_observable< Type, SpecificObservable >::op ( OperatorFn &&  fn ) const &

inline

The apply function to observable which returns observable of another type.

Template Parameters

OperatorFn

type of function which applies to this observable

Returns

new specific_observable of NewType