RxCpp
The Reactive Extensions for Native (RxCpp) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators in both C and C++.
|
a source of values that records the time of each subscription/unsubscription and all the values and the time they were emitted. More...
#include <rx-test.hpp>
Public Types | |
typedef detail::test_subject_base< T >::recorded_type | recorded_type |
![]() | |
typedef rxu::decay_t< detail::test_source< T > > | source_operator_type |
typedef T | value_type |
![]() | |
typedef tag_observable | observable_tag |
typedef T | value_type |
Public Member Functions | |
testable_observable (test_subject ts) | |
std::vector< rxn::subscription > | subscriptions () const |
std::vector< recorded_type > | messages () const |
![]() | |
observable () | |
observable (const source_operator_type &o) | |
observable (source_operator_type &&o) | |
observable (const observable< T, SO > &o) | |
implicit conversion between observables of the same value_type More... | |
observable (observable< T, SO > &&o) | |
implicit conversion between observables of the same value_type More... | |
~observable () | |
observable< T > | as_dynamic (AN **...) const |
blocking_observable< T, this_type > | as_blocking (AN **...) const |
auto | subscribe (ArgN &&... an) const -> composite_subscription |
auto | all (AN &&... an) const |
auto | is_empty (AN &&... an) const |
Returns an Observable that emits true if the source Observable is empty, otherwise false. More... | |
auto | any (AN &&... an) const |
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... | |
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... | |
auto | filter (AN &&... an) const |
auto | switch_if_empty (AN &&... an) const |
auto | default_if_empty (AN &&... an) const |
If the source Observable terminates without emitting any items, emits a default item and completes. More... | |
auto | sequence_equal (AN... an) const |
auto | tap (AN &&... an) const |
auto | time_interval (AN &&... an) const |
auto | timeout (AN &&... an) const |
auto | timestamp (AN &&... an) const |
auto | finally (AN &&... an) const |
auto | on_error_resume_next (AN &&... an) const |
auto | switch_on_error (AN &&... an) const |
auto | map (AN &&... an) const |
auto | transform (AN &&... an) const |
auto | debounce (AN &&... an) const |
auto | delay (AN &&... an) const |
auto | distinct (AN &&... an) const |
auto | distinct_until_changed (AN &&... an) const |
auto | element_at (AN &&... an) const |
auto | window (AN &&... an) const |
auto | window_with_time (AN &&... an) const |
auto | window_with_time_or_count (AN &&... an) const |
auto | window_toggle (AN &&... an) const |
auto | buffer (AN &&... an) const |
auto | buffer_with_time (AN &&... an) const |
auto | buffer_with_time_or_count (AN &&... an) const |
auto | switch_on_next (AN &&... an) const |
auto | merge (AN... an) const |
auto | merge_delay_error (AN... an) const |
auto | amb (AN... an) const |
auto | flat_map (AN &&... an) const |
auto | merge_transform (AN &&... an) const |
auto | concat (AN... an) const |
auto | concat_map (AN &&... an) const |
auto | concat_transform (AN &&... an) const |
auto | with_latest_from (AN... an) const |
auto | combine_latest (AN... an) const |
auto | zip (AN &&... an) const |
auto | group_by (AN &&... an) const |
auto | ignore_elements (AN &&... an) const |
auto | multicast (AN &&... an) const |
auto | publish (AN &&... an) const |
auto | publish_synchronized (AN &&... an) const |
Turn a cold observable hot and allow connections to the source to be independent of subscriptions. More... | |
auto | replay (AN &&... an) const |
auto | subscribe_on (AN &&... an) const |
auto | observe_on (AN &&... an) const |
auto | reduce (AN &&... an) const |
auto | accumulate (AN &&... an) const |
auto | first (AN **...) const |
For each item from this observable reduce it by sending only the first item. More... | |
auto | last (AN **...) const |
For each item from this observable reduce it by sending only the last item. More... | |
auto | count (AN **...) const |
For each item from this observable reduce it by incrementing a count. More... | |
auto | sum (AN **...) const |
For each item from this observable reduce it by adding to the previous items. More... | |
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... | |
auto | max (AN **...) const |
For each item from this observable reduce it by taking the max value of the previous items. More... | |
auto | min (AN **...) const |
For each item from this observable reduce it by taking the min value of the previous items. More... | |
auto | scan (AN... an) const |
auto | sample_with_time (AN &&... an) const |
auto | skip (AN... an) const |
auto | skip_while (AN... an) const |
auto | skip_last (AN... an) const |
auto | skip_until (AN... an) const |
auto | take (AN... an) const |
auto | take_last (AN &&... an) const |
auto | take_until (AN &&... an) const |
auto | take_while (AN &&... an) const |
auto | repeat (AN... an) const |
auto | retry (AN... an) const |
auto | start_with (AN... an) const |
auto | pairwise (AN... an) const |
Additional Inherited Members | |
![]() | |
source_operator_type | source_operator |
a source of values that records the time of each subscription/unsubscription and all the values and the time they were emitted.
typedef detail::test_subject_base<T>::recorded_type rxcpp::test::testable_observable< T >::recorded_type |
|
inlineexplicit |
|
inline |
|
inline |