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>
Inheritance diagram for rxcpp::test::testable_observable< T >:
Collaboration diagram for rxcpp::test::testable_observable< T >:
Public Types | |
| typedef detail::test_subject_base< T >::recorded_type | recorded_type |
 Public Types inherited from rxcpp::observable< T, detail::test_source< T > > | |
| typedef rxu::decay_t< detail::test_source< T > > | source_operator_type |
| typedef T | value_type |
| Public Types inherited from rxcpp::observable_base< T > | |
| 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 |
| Public Member Functions inherited from rxcpp::observable< T, detail::test_source< T > > | |
| 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 | |
| Public Attributes inherited from rxcpp::observable< T, detail::test_source< T > > | |
| source_operator_type | source_operator |
Detailed Description
template<class T>
class rxcpp::test::testable_observable< T >
a source of values that records the time of each subscription/unsubscription and all the values and the time they were emitted.
Member Typedef Documentation
◆ recorded_type
template<class T >
| typedef detail::test_subject_base<T>::recorded_type rxcpp::test::testable_observable< T >::recorded_type |
Constructor & Destructor Documentation
◆ testable_observable()
template<class T >
|
inlineexplicit |
Member Function Documentation
◆ messages()
template<class T >
|
inline |
◆ subscriptions()
template<class T >
|
inline |
The documentation for this class was generated from the following file:
- /builddir/build/BUILD/RxCpp-4.1.0/Rx/v2/src/rxcpp/rx-test.hpp
