C++ Reactive Programming

Filtering Operators

The ability to filter Streams is a common activity in Stream processing. It is not unusual that the Rx programming model defines a lot of Operators in the filtering category. Filtering operators are mostly predicate functions or lambdas. The following table contains a list of filtering  Operators:

Observables	Description
debounce	Observable that emits an item if a particular time span has passed without emitting another item from the source Observable
distinct	Observable that emits those items from the source Observable that are distinct
element_at	Observable that emits an item located at a specified index location
filter	Observable that emits only those items emitted by the source Observable ...