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++.
Public Types | Public Member Functions | List of all members
rxcpp::test::testable_observable< T > Class Template Reference

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 >:
Inheritance graph
[legend]
Collaboration diagram for rxcpp::test::testable_observable< T >:
Collaboration graph
[legend]

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::subscriptionsubscriptions () const
 
std::vector< recorded_typemessages () 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_typeas_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 >
rxcpp::test::testable_observable< T >::testable_observable ( test_subject  ts)
inlineexplicit

Member Function Documentation

◆ messages()

template<class T >
std::vector<recorded_type> rxcpp::test::testable_observable< T >::messages ( ) const
inline

◆ subscriptions()

template<class T >
std::vector<rxn::subscription> rxcpp::test::testable_observable< T >::subscriptions ( ) const
inline

The documentation for this class was generated from the following file: