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

Go to the source code of this file.

Classes

class  rxcpp::dynamic_observable< T >
 
struct  rxcpp::defer_observable< Selector, Default, SO, AN >
 
class  rxcpp::blocking_observable< T, Observable >
 a source of values whose methods block until all values have been emitted. subscribe or use one of the operator methods that reduce the values emitted to a single value. More...
 
class  rxcpp::observable< T, SourceOperator >
 a source of values. subscribe or use one of the operator methods that return a new observable, which uses this observable as a source. More...
 
class  rxcpp::observable< void, void >
 typed as rxcpp::observable<>, this is a collection of factory methods that return an observable. More...
 

Namespaces

 rxcpp
 

Macros

#define RXCPP_RX_OBSERVABLE_HPP
 
#define EXPLICIT_THIS
 

Functions

template<class T >
bool rxcpp::operator== (const dynamic_observable< T > &lhs, const dynamic_observable< T > &rhs)
 
template<class T >
bool rxcpp::operator!= (const dynamic_observable< T > &lhs, const dynamic_observable< T > &rhs)
 
template<class T , class Source >
observable< T > rxcpp::make_observable_dynamic (Source &&s)
 
template<class T , class SourceOperator >
bool rxcpp::operator== (const observable< T, SourceOperator > &lhs, const observable< T, SourceOperator > &rhs)
 
template<class T , class SourceOperator >
bool rxcpp::operator!= (const observable< T, SourceOperator > &lhs, const observable< T, SourceOperator > &rhs)
 
template<class T , class SourceOperator , class OperatorFactory >
auto operator>> (const rxcpp::observable< T, SourceOperator > &source, OperatorFactory &&of) -> decltype(source.op(std::forward< OperatorFactory >(of)))
 
template<class T , class SourceOperator , class OperatorFactory >
auto operator| (const rxcpp::observable< T, SourceOperator > &source, OperatorFactory &&of) -> decltype(source.op(std::forward< OperatorFactory >(of)))
 

Macro Definition Documentation

#define EXPLICIT_THIS
#define RXCPP_RX_OBSERVABLE_HPP

Function Documentation

template<class T , class SourceOperator , class OperatorFactory >
auto operator>> ( const rxcpp::observable< T, SourceOperator > &  source,
OperatorFactory &&  of 
) -> decltype(source.op(std::forward<OperatorFactory>(of)))
template<class T , class SourceOperator , class OperatorFactory >
auto operator| ( const rxcpp::observable< T, SourceOperator > &  source,
OperatorFactory &&  of 
) -> decltype(source.op(std::forward<OperatorFactory>(of)))