a source of values. subscribe or use one of the operator methods that return a new observable, which uses this observable as a source.
More...
|
| ~observable () |
|
| observable () |
|
| observable (const source_operator_type &o) |
|
| observable (source_operator_type &&o) |
|
template<class SO > |
| observable (const observable< T, SO > &o) |
| implicit conversion between observables of the same value_type More...
|
|
template<class SO > |
| observable (observable< T, SO > &&o) |
| implicit conversion between observables of the same value_type More...
|
|
template<class... AN> |
observable< T > | as_dynamic (AN **...) const |
|
template<class... AN> |
blocking_observable< T, this_type > | as_blocking (AN **...) const |
|
template<class... ArgN> |
auto | subscribe (ArgN &&... an) const -> composite_subscription |
|
template<class... AN> |
auto | all (AN &&... an) const |
|
template<class... AN> |
auto | is_empty (AN &&... an) const |
| Returns an Observable that emits true if the source Observable is empty, otherwise false. More...
|
|
template<class... AN> |
auto | any (AN &&... an) const |
|
template<class... AN> |
auto | exists (AN &&... an) const |
| Returns an Observable that emits true if any item emitted by the source Observable satisfies a specified condition, otherwise false. Emits false if the source Observable terminates without emitting any item. More...
|
|
template<class... AN> |
auto | contains (AN &&... an) const |
| Returns an Observable that emits true if the source Observable emitted a specified item, otherwise false. Emits false if the source Observable terminates without emitting any item. More...
|
|
template<class... AN> |
auto | filter (AN &&... an) const |
|
template<class... AN> |
auto | switch_if_empty (AN &&... an) const |
|
template<class... AN> |
auto | default_if_empty (AN &&... an) const |
| If the source Observable terminates without emitting any items, emits a default item and completes. More...
|
|
template<class... AN> |
auto | sequence_equal (AN... an) const |
|
template<class... AN> |
auto | tap (AN &&... an) const |
|
template<class... AN> |
auto | time_interval (AN &&... an) const |
|
template<class... AN> |
auto | timeout (AN &&... an) const |
|
template<class... AN> |
auto | timestamp (AN &&... an) const |
|
template<class... AN> |
auto | finally (AN &&... an) const |
|
template<class... AN> |
auto | on_error_resume_next (AN &&... an) const |
|
template<class... AN> |
auto | switch_on_error (AN &&... an) const |
|
template<class... AN> |
auto | map (AN &&... an) const |
|
template<class... AN> |
auto | transform (AN &&... an) const |
|
template<class... AN> |
auto | debounce (AN &&... an) const |
|
template<class... AN> |
auto | delay (AN &&... an) const |
|
template<class... AN> |
auto | distinct (AN &&... an) const |
|
template<class... AN> |
auto | distinct_until_changed (AN &&... an) const |
|
template<class... AN> |
auto | element_at (AN &&... an) const |
|
template<class... AN> |
auto | window (AN &&... an) const |
|
template<class... AN> |
auto | window_with_time (AN &&... an) const |
|
template<class... AN> |
auto | window_with_time_or_count (AN &&... an) const |
|
template<class... AN> |
auto | window_toggle (AN &&... an) const |
|
template<class... AN> |
auto | buffer (AN &&... an) const |
|
template<class... AN> |
auto | buffer_with_time (AN &&... an) const |
|
template<class... AN> |
auto | buffer_with_time_or_count (AN &&... an) const |
|
template<class... AN> |
auto | switch_on_next (AN &&... an) const |
|
template<class... AN> |
auto | merge (AN... an) const |
|
template<class... AN> |
auto | merge_delay_error (AN... an) const |
|
template<class... AN> |
auto | amb (AN... an) const |
|
template<class... AN> |
auto | flat_map (AN &&... an) const |
|
template<class... AN> |
auto | merge_transform (AN &&... an) const |
|
template<class... AN> |
auto | concat (AN... an) const |
|
template<class... AN> |
auto | concat_map (AN &&... an) const |
|
template<class... AN> |
auto | concat_transform (AN &&... an) const |
|
template<class... AN> |
auto | with_latest_from (AN... an) const |
|
template<class... AN> |
auto | combine_latest (AN... an) const |
|
template<class... AN> |
auto | zip (AN &&... an) const |
|
template<class... AN> |
auto | group_by (AN &&... an) const |
|
template<class... AN> |
auto | ignore_elements (AN &&... an) const |
|
template<class... AN> |
auto | multicast (AN &&... an) const |
|
template<class... AN> |
auto | publish (AN &&... an) const |
|
template<class... AN> |
auto | publish_synchronized (AN &&... an) const |
| Turn a cold observable hot and allow connections to the source to be independent of subscriptions. More...
|
|
template<class... AN> |
auto | replay (AN &&... an) const |
|
template<class... AN> |
auto | subscribe_on (AN &&... an) const |
|
template<class... AN> |
auto | observe_on (AN &&... an) const |
|
template<class... AN> |
auto | reduce (AN &&... an) const |
|
template<class... AN> |
auto | accumulate (AN &&... an) const |
|
template<class... AN> |
auto | first (AN **...) const |
| For each item from this observable reduce it by sending only the first item. More...
|
|
template<class... AN> |
auto | last (AN **...) const |
| For each item from this observable reduce it by sending only the last item. More...
|
|
template<class... AN> |
auto | count (AN **...) const |
| For each item from this observable reduce it by incrementing a count. More...
|
|
template<class... AN> |
auto | sum (AN **...) const |
| For each item from this observable reduce it by adding to the previous items. More...
|
|
template<class... AN> |
auto | average (AN **...) const |
| For each item from this observable reduce it by adding to the previous values and then dividing by the number of items at the end. More...
|
|
template<class... AN> |
auto | max (AN **...) const |
| For each item from this observable reduce it by taking the max value of the previous items. More...
|
|
template<class... AN> |
auto | min (AN **...) const |
| For each item from this observable reduce it by taking the min value of the previous items. More...
|
|
template<class... AN> |
auto | scan (AN... an) const |
|
template<class... AN> |
auto | sample_with_time (AN &&... an) const |
|
template<class... AN> |
auto | skip (AN... an) const |
|
template<class... AN> |
auto | skip_while (AN... an) const |
|
template<class... AN> |
auto | skip_last (AN... an) const |
|
template<class... AN> |
auto | skip_until (AN... an) const |
|
template<class... AN> |
auto | take (AN... an) const |
|
template<class... AN> |
auto | take_last (AN &&... an) const |
|
template<class... AN> |
auto | take_until (AN &&... an) const |
|
template<class... AN> |
auto | take_while (AN &&... an) const |
|
template<class... AN> |
auto | repeat (AN... an) const |
|
template<class... AN> |
auto | retry (AN... an) const |
|
template<class... AN> |
auto | start_with (AN... an) const |
|
template<class... AN> |
auto | pairwise (AN... an) const |
|
template<class T, class SourceOperator>
class rxcpp::observable< T, SourceOperator >
a source of values. subscribe or use one of the operator methods that return a new observable, which uses this observable as a source.
- Some code
- This sample will observable::subscribe() to values from a observable<void, void>::range().
- Sample Code\n
values1.
[](int v){printf("OnNext: %d\n", v);},
[](){printf("OnCompleted\n");});
OnNext: 1
OnNext: 2
OnNext: 3
OnNext: 4
OnNext: 5
OnCompleted