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 | Typedefs | Functions
rx-operators.hpp File Reference
#include "rx-includes.hpp"
#include "operators/rx-lift.hpp"
#include "operators/rx-subscribe.hpp"
#include "operators/rx-multicast.hpp"
#include "operators/rx-publish.hpp"
#include "operators/rx-ref_count.hpp"
Include dependency graph for rx-operators.hpp:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes

struct  rxcpp::operators::tag_operator
 
struct  rxcpp::operators::operator_base< T >
 
struct  rxcpp::operators::is_operator< T, Decayed >
 
struct  rxcpp::member_overload< Tag >
 
struct  rxcpp::delayed_type< T, AN >
 
class  rxcpp::operator_factory< Tag, AN >
 
struct  rxcpp::amb_tag
 
struct  rxcpp::amb_tag::include_header< Included >
 
struct  rxcpp::all_tag
 
struct  rxcpp::all_tag::include_header< Included >
 
struct  rxcpp::is_empty_tag
 
struct  rxcpp::any_tag
 
struct  rxcpp::any_tag::include_header< Included >
 
struct  rxcpp::exists_tag
 
struct  rxcpp::contains_tag
 
struct  rxcpp::buffer_count_tag
 
struct  rxcpp::buffer_count_tag::include_header< Included >
 
struct  rxcpp::buffer_with_time_tag
 
struct  rxcpp::buffer_with_time_tag::include_header< Included >
 
struct  rxcpp::buffer_with_time_or_count_tag
 
struct  rxcpp::buffer_with_time_or_count_tag::include_header< Included >
 
struct  rxcpp::combine_latest_tag
 
struct  rxcpp::combine_latest_tag::include_header< Included >
 
struct  rxcpp::concat_tag
 
struct  rxcpp::concat_tag::include_header< Included >
 
struct  rxcpp::concat_map_tag
 
struct  rxcpp::concat_map_tag::include_header< Included >
 
struct  rxcpp::connect_forever_tag
 
struct  rxcpp::connect_forever_tag::include_header< Included >
 
struct  rxcpp::debounce_tag
 
struct  rxcpp::debounce_tag::include_header< Included >
 
struct  rxcpp::delay_tag
 
struct  rxcpp::delay_tag::include_header< Included >
 
struct  rxcpp::distinct_tag
 
struct  rxcpp::distinct_tag::include_header< Included >
 
struct  rxcpp::distinct_until_changed_tag
 
struct  rxcpp::distinct_until_changed_tag::include_header< Included >
 
struct  rxcpp::element_at_tag
 
struct  rxcpp::element_at_tag::include_header< Included >
 
struct  rxcpp::filter_tag
 
struct  rxcpp::filter_tag::include_header< Included >
 
struct  rxcpp::finally_tag
 
struct  rxcpp::finally_tag::include_header< Included >
 
struct  rxcpp::flat_map_tag
 
struct  rxcpp::flat_map_tag::include_header< Included >
 
struct  rxcpp::group_by_tag
 
struct  rxcpp::group_by_tag::include_header< Included >
 
struct  rxcpp::ignore_elements_tag
 
struct  rxcpp::ignore_elements_tag::include_header< Included >
 
struct  rxcpp::map_tag
 
struct  rxcpp::map_tag::include_header< Included >
 
struct  rxcpp::merge_tag
 
struct  rxcpp::merge_tag::include_header< Included >
 
struct  rxcpp::multicast_tag
 
struct  rxcpp::multicast_tag::include_header< Included >
 
struct  rxcpp::observe_on_tag
 
struct  rxcpp::observe_on_tag::include_header< Included >
 
struct  rxcpp::on_error_resume_next_tag
 
struct  rxcpp::on_error_resume_next_tag::include_header< Included >
 
class  rxcpp::empty_error
 
struct  rxcpp::reduce_tag
 
struct  rxcpp::reduce_tag::include_header< Included >
 
struct  rxcpp::first_tag
 
struct  rxcpp::last_tag
 
struct  rxcpp::sum_tag
 
struct  rxcpp::average_tag
 
struct  rxcpp::min_tag
 
struct  rxcpp::max_tag
 
struct  rxcpp::ref_count_tag
 
struct  rxcpp::ref_count_tag::include_header< Included >
 
struct  rxcpp::pairwise_tag
 
struct  rxcpp::pairwise_tag::include_header< Included >
 
struct  rxcpp::publish_tag
 
struct  rxcpp::publish_tag::include_header< Included >
 
struct  rxcpp::publish_synchronized_tag
 
struct  rxcpp::repeat_tag
 
struct  rxcpp::repeat_tag::include_header< Included >
 
struct  rxcpp::replay_tag
 
struct  rxcpp::replay_tag::include_header< Included >
 
struct  rxcpp::retry_tag
 
struct  rxcpp::retry_tag::include_header< Included >
 
struct  rxcpp::sample_with_time_tag
 
struct  rxcpp::sample_with_time_tag::include_header< Included >
 
struct  rxcpp::scan_tag
 
struct  rxcpp::scan_tag::include_header< Included >
 
struct  rxcpp::sequence_equal_tag
 
struct  rxcpp::sequence_equal_tag::include_header< Included >
 
struct  rxcpp::skip_tag
 
struct  rxcpp::skip_tag::include_header< Included >
 
struct  rxcpp::skip_last_tag
 
struct  rxcpp::skip_last_tag::include_header< Included >
 
struct  rxcpp::skip_until_tag
 
struct  rxcpp::skip_until_tag::include_header< Included >
 
struct  rxcpp::start_with_tag
 
struct  rxcpp::start_with_tag::include_header< Included >
 
struct  rxcpp::subscribe_on_tag
 
struct  rxcpp::subscribe_on_tag::include_header< Included >
 
struct  rxcpp::switch_if_empty_tag
 
struct  rxcpp::switch_if_empty_tag::include_header< Included >
 
struct  rxcpp::default_if_empty_tag
 
struct  rxcpp::switch_on_next_tag
 
struct  rxcpp::switch_on_next_tag::include_header< Included >
 
struct  rxcpp::take_tag
 
struct  rxcpp::take_tag::include_header< Included >
 
struct  rxcpp::take_last_tag
 
struct  rxcpp::take_last_tag::include_header< Included >
 
struct  rxcpp::take_while_tag
 
struct  rxcpp::take_while_tag::include_header< Included >
 
struct  rxcpp::take_until_tag
 
struct  rxcpp::take_until_tag::include_header< Included >
 
struct  rxcpp::tap_tag
 
struct  rxcpp::tap_tag::include_header< Included >
 
struct  rxcpp::timeout_tag
 
struct  rxcpp::timeout_tag::include_header< Included >
 
struct  rxcpp::time_interval_tag
 
struct  rxcpp::time_interval_tag::include_header< Included >
 
struct  rxcpp::timestamp_tag
 
struct  rxcpp::timestamp_tag::include_header< Included >
 
struct  rxcpp::window_tag
 
struct  rxcpp::window_tag::include_header< Included >
 
struct  rxcpp::window_with_time_tag
 
struct  rxcpp::window_with_time_tag::include_header< Included >
 
struct  rxcpp::window_with_time_or_count_tag
 
struct  rxcpp::window_with_time_or_count_tag::include_header< Included >
 
struct  rxcpp::window_toggle_tag
 
struct  rxcpp::window_toggle_tag::include_header< Included >
 
struct  rxcpp::with_latest_from_tag
 
struct  rxcpp::with_latest_from_tag::include_header< Included >
 
struct  rxcpp::zip_tag
 
struct  rxcpp::zip_tag::include_header< Included >
 

Namespaces

 rxcpp
 
 rxcpp::operators
 

Macros

#define RXCPP_RX_OPERATORS_HPP
 

Typedefs

template<class T , class... AN>
using rxcpp::delayed_type_t = rxu::value_type_t< delayed_type< T, AN... >>
 

Functions

template<class Tag , class... AN, class Overload = member_overload<rxu::decay_t<Tag>>>
auto rxcpp::observable_member (Tag, AN &&...an) -> decltype(Overload::member(std::forward< AN >(an)...))
 

Macro Definition Documentation

#define RXCPP_RX_OPERATORS_HPP