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++.
|
#include <rx-test.hpp>
Public Types | |
typedef detail::test_subject_base< T >::recorded_type | recorded_type |
Public Types inherited from rxcpp::observer< T > | |
using | this_type = observer< T, State, OnNext, OnError, OnCompleted > |
using | state_t = rxu::decay_t< State > |
using | on_next_t = typename std::conditional< !std::is_same< void, OnNext >::value, rxu::decay_t< OnNext >, detail::OnNextForward< T, State, OnNext >>::type |
using | on_error_t = typename std::conditional< !std::is_same< void, OnError >::value, rxu::decay_t< OnError >, detail::OnErrorForward< State, OnError >>::type |
using | on_completed_t = typename std::conditional< !std::is_same< void, OnCompleted >::value, rxu::decay_t< OnCompleted >, detail::OnCompletedForward< State, OnCompleted >>::type |
Public Types inherited from rxcpp::observer_base< T > | |
typedef T | value_type |
typedef tag_observer | observer_tag |
Public Member Functions | |
testable_observer (test_subject ts, observer_base ob) | |
std::vector< recorded_type > | messages () const |
Public Member Functions inherited from rxcpp::observer< T > | |
observer (state_t s, on_next_t n=on_next_t(), on_error_t e=on_error_t(), on_completed_t c=on_completed_t()) | |
observer (state_t s, on_next_t n, on_completed_t c) | |
observer (const this_type &o) | |
observer (this_type &&o) | |
this_type & | operator= (this_type o) |
void | on_next (T &t) const |
void | on_next (T &&t) const |
void | on_error (std::exception_ptr e) const |
void | on_completed () const |
observer< T > | as_dynamic () const |
typedef detail::test_subject_base<T>::recorded_type rxcpp::test::testable_observer< T >::recorded_type |
|
inline |
|
inline |