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++.
Classes | Namespaces | Macros | Functions
rx-observer.hpp File Reference
#include "rx-includes.hpp"
Include dependency graph for rx-observer.hpp:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes

struct  rxcpp::observer_base< T >
 
class  rxcpp::observer< T, State, OnNext, OnError, OnCompleted >
 consumes values from an observable using State that may implement on_next, on_error and on_completed with optional overrides of each function. More...
 
class  rxcpp::observer< T, void, void, void, void >
 consumes values from an observable using type-forgetting (shared allocated state with virtual methods) More...
 

Namespaces

 rxcpp
 

Macros

#define RXCPP_RX_OBSERVER_HPP
 

Functions

template<class T , class DefaultOnError = detail::OnErrorEmpty>
auto rxcpp::make_observer () -> observer< T, detail::stateless_observer_tag, detail::OnNextEmpty< T >, DefaultOnError >
 
template<class T , class DefaultOnError = detail::OnErrorEmpty, class U , class State , class OnNext , class OnError , class OnCompleted >
auto rxcpp::make_observer (observer< U, State, OnNext, OnError, OnCompleted > o) -> observer< T, State, OnNext, OnError, OnCompleted >
 
template<class T , class DefaultOnError = detail::OnErrorEmpty, class Observer >
auto rxcpp::make_observer (Observer ob) -> typename std::enable_if< !detail::is_on_next_of< T, Observer >::value && !detail::is_on_error< Observer >::value && is_observer< Observer >::value, Observer >::type
 
template<class T , class DefaultOnError = detail::OnErrorEmpty, class OnNext >
auto rxcpp::make_observer (OnNext on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, observer< T, detail::stateless_observer_tag, OnNext, DefaultOnError >>::type
 
template<class T , class DefaultOnError = detail::OnErrorEmpty, class OnError >
auto rxcpp::make_observer (OnError oe) -> typename std::enable_if< detail::is_on_error< OnError >::value, observer< T, detail::stateless_observer_tag, detail::OnNextEmpty< T >, OnError >>::type
 
template<class T , class DefaultOnError = detail::OnErrorEmpty, class OnNext , class OnError >
auto rxcpp::make_observer (OnNext on, OnError oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, observer< T, detail::stateless_observer_tag, OnNext, OnError >>::type
 
template<class T , class DefaultOnError = detail::OnErrorEmpty, class OnNext , class OnCompleted >
auto rxcpp::make_observer (OnNext on, OnCompleted oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, observer< T, detail::stateless_observer_tag, OnNext, DefaultOnError, OnCompleted >>::type
 
template<class T , class DefaultOnError = detail::OnErrorEmpty, class OnNext , class OnError , class OnCompleted >
auto rxcpp::make_observer (OnNext on, OnError oe, OnCompleted oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value && detail::is_on_completed< OnCompleted >::value, observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >>::type
 
template<class T , class State , class OnNext >
auto rxcpp::make_observer (State os, OnNext on) -> typename std::enable_if< !detail::is_on_next_of< T, State >::value && !detail::is_on_error< State >::value, observer< T, State, OnNext >>::type
 
template<class T , class State , class OnError >
auto rxcpp::make_observer (State os, OnError oe) -> typename std::enable_if< !detail::is_on_next_of< T, State >::value && !detail::is_on_error< State >::value && detail::is_on_error_for< State, OnError >::value, observer< T, State, detail::OnNextEmpty< T >, OnError >>::type
 
template<class T , class State , class OnNext , class OnError >
auto rxcpp::make_observer (State os, OnNext on, OnError oe) -> typename std::enable_if< !detail::is_on_next_of< T, State >::value && !detail::is_on_error< State >::value && detail::is_on_error_for< State, OnError >::value, observer< T, State, OnNext, OnError >>::type
 
template<class T , class State , class OnNext , class OnCompleted >
auto rxcpp::make_observer (State os, OnNext on, OnCompleted oc) -> typename std::enable_if< !detail::is_on_next_of< T, State >::value && !detail::is_on_error< State >::value, observer< T, State, OnNext, void, OnCompleted >>::type
 
template<class T , class State , class OnNext , class OnError , class OnCompleted >
auto rxcpp::make_observer (State os, OnNext on, OnError oe, OnCompleted oc) -> typename std::enable_if< !detail::is_on_next_of< T, State >::value && !detail::is_on_error< State >::value && detail::is_on_error_for< State, OnError >::value, observer< T, State, OnNext, OnError, OnCompleted >>::type
 
template<class T , class Observer >
auto rxcpp::make_observer_dynamic (Observer o) -> typename std::enable_if< !detail::is_on_next_of< T, Observer >::value, observer< T >>::type
 
template<class T , class OnNext >
auto rxcpp::make_observer_dynamic (OnNext &&on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, observer< T >>::type
 
template<class T , class OnNext , class OnError >
auto rxcpp::make_observer_dynamic (OnNext &&on, OnError &&oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, observer< T >>::type
 
template<class T , class OnNext , class OnCompleted >
auto rxcpp::make_observer_dynamic (OnNext &&on, OnCompleted &&oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, observer< T >>::type
 
template<class T , class OnNext , class OnError , class OnCompleted >
auto rxcpp::make_observer_dynamic (OnNext &&on, OnError &&oe, OnCompleted &&oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value && detail::is_on_completed< OnCompleted >::value, observer< T >>::type
 
template<class F , class OnError >
auto rxcpp::on_exception (const F &f, const OnError &c) -> typename std::enable_if< detail::is_on_error< OnError >::value, typename detail::maybe_from_result< F >::type >::type
 
template<class F , class Subscriber >
auto rxcpp::on_exception (const F &f, const Subscriber &s) -> typename std::enable_if< is_subscriber< Subscriber >::value, typename detail::maybe_from_result< F >::type >::type
 

Macro Definition Documentation

#define RXCPP_RX_OBSERVER_HPP