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++.
|
consumes values from an observable using type-forgetting (shared allocated state with virtual methods) More...
#include <rx-observer.hpp>
Public Types | |
typedef tag_dynamic_observer | dynamic_observer_tag |
Public Types inherited from rxcpp::observer_base< T > | |
typedef T | value_type |
typedef tag_observer | observer_tag |
Public Member Functions | |
observer () | |
observer (const this_type &o) | |
observer (this_type &&o) | |
template<class Observer > | |
observer (Observer o) | |
this_type & | operator= (this_type o) |
template<class V > | |
void | on_next (V &&v) const |
void | on_error (std::exception_ptr e) const |
void | on_completed () const |
observer< T > | as_dynamic () const |
consumes values from an observable using type-forgetting (shared allocated state with virtual methods)
T | - the type of value in the stream |
typedef tag_dynamic_observer rxcpp::observer< T, void, void, void, void >::dynamic_observer_tag |
|
inline |
|
inline |
|
inline |
|
inlineexplicit |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |