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-connectable_observable.hpp File Reference
#include "rx-includes.hpp"
Include dependency graph for rx-connectable_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_connectable_observable< T >
 
class  rxcpp::connectable_observable< T, SourceOperator >
 a source of values that is shared across all subscribers and does not start until connectable_observable::connect() is called. More...
 

Namespaces

 rxcpp
 

Macros

#define RXCPP_RX_CONNECTABLE_OBSERVABLE_HPP
 

Functions

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

Macro Definition Documentation

#define RXCPP_RX_CONNECTABLE_OBSERVABLE_HPP

Function Documentation

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