rxcpp Namespace Reference

Namespaces
	notifications
	operators
	schedulers
	sources
	subjects
	test
	util

Classes
struct	all_tag
struct	amb_tag
struct	any_tag
struct	average_tag
class	blocking_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...
struct	buffer_count_tag
struct	buffer_with_time_or_count_tag
struct	buffer_with_time_tag
struct	combine_latest_tag
class	composite_subscription
	controls lifetime for scheduler::schedule and observable<T, SourceOperator>::subscribe. More...
struct	concat_map_tag
struct	concat_tag
struct	connect_forever_tag
class	connectable_observable
	a source of values that is shared across all subscribers and does not start until connectable_observable::connect() is called. More...
struct	contains_tag
struct	coordination_base
class	coordinator
struct	coordinator_base
struct	debounce_tag
struct	default_if_empty_tag
struct	defer_observable
struct	delay_tag
struct	delayed_type
struct	distinct_tag
struct	distinct_until_changed_tag
class	dynamic_connectable_observable
class	dynamic_grouped_observable
class	dynamic_observable
struct	element_at_tag
class	empty_error
struct	exists_tag
struct	expand_observable_tags
struct	expand_observable_tags< rxu::types< ObservableN... >, rxu::types_checked_t< typename ObservableN::observable_tag... > >
struct	filter_tag
struct	filtered_hash
struct	filtered_hash< T, typename std::enable_if< rxu::is_string< T >::value >::type >
struct	filtered_hash< T, typename std::enable_if< std::is_convertible< T, std::chrono::duration< typename T::rep, typename T::period > >::value >::type >
struct	filtered_hash< T, typename std::enable_if< std::is_convertible< T, std::chrono::time_point< typename T::clock, typename T::duration > >::value >::type >
struct	filtered_hash< T, typename std::enable_if< std::is_enum< T >::value >::type >
struct	filtered_hash< T, typename std::enable_if< std::is_integral< T >::value >::type >
struct	filtered_hash< T, typename std::enable_if< std::is_pointer< T >::value >::type >
struct	finally_tag
struct	first_tag
struct	flat_map_tag
struct	group_by_tag
class	grouped_observable
	a source of observables which each emit values from one category specified by the key selector. More...
struct	identity_for
struct	identity_observable
class	identity_one_worker
struct	ignore_elements_tag
struct	is_accumulate_function_for
struct	is_action
struct	is_action< T, typename rxu::types_checked_from< typename T::action_tag >::type >
class	is_connectable_observable
struct	is_coordination
struct	is_coordinator
struct	is_coordinator< T, typename rxu::types_checked_from< typename T::coordinator_tag >::type >
class	is_dynamic_connectable_observable
class	is_dynamic_grouped_observable
class	is_dynamic_observable
class	is_dynamic_observer
struct	is_empty_tag
class	is_grouped_observable
struct	is_hashable
struct	is_hashable< T, typename rxu::types_checked_from< typename filtered_hash< T >::result_type, typename filtered_hash< T >::argument_type, typename std::result_of< filtered_hash< T >(T)>::type >::type >
struct	is_observable
class	is_observer
struct	is_operator_factory_for
class	is_schedulable
class	is_scheduler
class	is_subscriber
class	is_subscription
class	is_worker
struct	last_tag
struct	map_tag
struct	max_tag
struct	member_overload
struct	member_overload< all_tag >
struct	member_overload< amb_tag >
struct	member_overload< any_tag >
struct	member_overload< average_tag >
struct	member_overload< buffer_count_tag >
struct	member_overload< buffer_with_time_or_count_tag >
struct	member_overload< buffer_with_time_tag >
struct	member_overload< combine_latest_tag >
struct	member_overload< concat_map_tag >
struct	member_overload< concat_tag >
struct	member_overload< connect_forever_tag >
struct	member_overload< contains_tag >
struct	member_overload< debounce_tag >
struct	member_overload< default_if_empty_tag >
struct	member_overload< delay_tag >
struct	member_overload< distinct_tag >
struct	member_overload< distinct_until_changed_tag >
struct	member_overload< element_at_tag >
struct	member_overload< exists_tag >
struct	member_overload< filter_tag >
struct	member_overload< finally_tag >
struct	member_overload< first_tag >
struct	member_overload< flat_map_tag >
struct	member_overload< group_by_tag >
struct	member_overload< ignore_elements_tag >
struct	member_overload< is_empty_tag >
struct	member_overload< last_tag >
struct	member_overload< map_tag >
struct	member_overload< max_tag >
struct	member_overload< merge_tag >
struct	member_overload< min_tag >
struct	member_overload< multicast_tag >
struct	member_overload< observe_on_tag >
struct	member_overload< on_error_resume_next_tag >
struct	member_overload< pairwise_tag >
struct	member_overload< publish_synchronized_tag >
struct	member_overload< publish_tag >
struct	member_overload< reduce_tag >
struct	member_overload< ref_count_tag >
struct	member_overload< repeat_tag >
struct	member_overload< replay_tag >
struct	member_overload< retry_tag >
struct	member_overload< sample_with_time_tag >
struct	member_overload< scan_tag >
struct	member_overload< sequence_equal_tag >
struct	member_overload< skip_last_tag >
struct	member_overload< skip_tag >
struct	member_overload< skip_until_tag >
struct	member_overload< start_with_tag >
struct	member_overload< subscribe_on_tag >
struct	member_overload< sum_tag >
struct	member_overload< switch_if_empty_tag >
struct	member_overload< switch_on_next_tag >
struct	member_overload< take_last_tag >
struct	member_overload< take_tag >
struct	member_overload< take_until_tag >
struct	member_overload< take_while_tag >
struct	member_overload< tap_tag >
struct	member_overload< time_interval_tag >
struct	member_overload< timeout_tag >
struct	member_overload< timestamp_tag >
struct	member_overload< window_tag >
struct	member_overload< window_toggle_tag >
struct	member_overload< window_with_time_or_count_tag >
struct	member_overload< window_with_time_tag >
struct	member_overload< with_latest_from_tag >
struct	member_overload< zip_tag >
struct	merge_tag
struct	min_tag
struct	multicast_tag
class	observable
	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	observable< void, void >
	typed as rxcpp::observable<>, this is a collection of factory methods that return an observable. More...
struct	observable_base
class	observe_on_one_worker
struct	observe_on_tag
class	observer
	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	observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >
	consumes values from an observable using default empty method implementations with optional overrides of each function.
class	observer< T, void, void, void, void >
	consumes values from an observable using type-forgetting (shared allocated state with virtual methods) More...
struct	observer_base
struct	on_error_resume_next_tag
class	operator_factory
struct	pairwise_tag
struct	publish_synchronized_tag
struct	publish_tag
struct	reduce_tag
struct	ref_count_tag
struct	repeat_tag
struct	replay_tag
class	resource
struct	retry_tag
struct	sample_with_time_tag
struct	scan_tag
struct	sequence_equal_tag
class	serialize_one_worker
struct	skip_last_tag
struct	skip_tag
struct	skip_until_tag
struct	start_with_tag
class	static_subscription
struct	subscribe_on_tag
class	subscriber
	binds an observer that consumes values with a composite_subscription that controls lifetime. More...
struct	subscriber_base
class	subscription
struct	subscription_base
struct	sum_tag
struct	switch_if_empty_tag
struct	switch_on_next_tag
class	synchronize_in_one_worker
struct	tag_action
struct	tag_connectable_observable
struct	tag_coordination
struct	tag_coordinator
struct	tag_dynamic_connectable_observable
struct	tag_dynamic_grouped_observable
struct	tag_dynamic_observable
struct	tag_dynamic_observer
struct	tag_grouped_observable
struct	tag_observable
struct	tag_observer
struct	tag_schedulable
struct	tag_scheduler
struct	tag_subscriber
struct	tag_subscription
struct	tag_worker
struct	take_last_tag
struct	take_tag
struct	take_until_tag
struct	take_while_tag
struct	tap_tag
struct	time_interval_tag
class	timeout_error
struct	timeout_tag
struct	timestamp_tag
struct	trace_id
struct	trace_noop
struct	trace_tag
struct	window_tag
struct	window_toggle_tag
struct	window_with_time_or_count_tag
struct	window_with_time_tag
struct	with_latest_from_tag
struct	zip_tag

Typedefs
template<class Coordination , class DecayedCoordination = rxu::decay_t<Coordination>>
using	coordination_tag_t = typename DecayedCoordination::coordination_tag
template<class T , class... AN>
using	delayed_type_t = rxu::value_type_t< delayed_type< T, AN... >>
template<class Observable , class DecayedObservable = rxu::decay_t<Observable>>
using	observable_tag_t = typename DecayedObservable::observable_tag
template<class... ObservableN>
using	observable_tags_t = typename expand_observable_tags< rxu::types< ObservableN... >>::type
template<class... ObservableN>
using	all_observables = rxu::all_true_type< is_observable< ObservableN >... >

Functions
observe_on_one_worker	observe_on_run_loop (const rxsc::run_loop &rl)
observe_on_one_worker	observe_on_event_loop ()
observe_on_one_worker	observe_on_new_thread ()
template<class T , class Source >
connectable_observable< T >	make_dynamic_connectable_observable (Source &&s)
identity_one_worker	identity_immediate ()
identity_one_worker	identity_current_thread ()
identity_one_worker	identity_same_worker (rxsc::worker w)
serialize_one_worker	serialize_event_loop ()
serialize_one_worker	serialize_new_thread ()
serialize_one_worker	serialize_same_worker (rxsc::worker w)
template<class K , class T >
bool	operator== (const dynamic_grouped_observable< K, T > &lhs, const dynamic_grouped_observable< K, T > &rhs)
template<class K , class T >
bool	operator!= (const dynamic_grouped_observable< K, T > &lhs, const dynamic_grouped_observable< K, T > &rhs)
template<class K , class T , class Source >
grouped_observable< K, T >	make_dynamic_grouped_observable (Source &&s)
template<class T >
bool	operator== (const dynamic_observable< T > &lhs, const dynamic_observable< T > &rhs)
template<class T >
bool	operator!= (const dynamic_observable< T > &lhs, const dynamic_observable< T > &rhs)
template<class T , class Source >
observable< T >	make_observable_dynamic (Source &&s)
template<class T , class SourceOperator >
bool	operator== (const observable< T, SourceOperator > &lhs, const observable< T, SourceOperator > &rhs)
template<class T , class SourceOperator >
bool	operator!= (const observable< T, SourceOperator > &lhs, const observable< T, SourceOperator > &rhs)
template<class T , class DefaultOnError = detail::OnErrorEmpty>
auto	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	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	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	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	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	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	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	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	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	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	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	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	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	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	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	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	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	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	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	on_exception (const F &f, const Subscriber &s) -> typename std::enable_if< is_subscriber< Subscriber >::value, typename detail::maybe_from_result< F >::type >::type
template<class Tag , class... AN, class Overload = member_overload<rxu::decay_t<Tag>>>
auto	observable_member (Tag, AN &&...an) -> decltype(Overload::member(std::forward< AN >(an)...))
auto	trace_activity () -> decltype(rxcpp_trace_activity(trace_tag()))&
template<class T , class Observer >
auto	make_subscriber (subscriber< T, Observer > o) -> subscriber< T, Observer >
template<class T >
auto	make_subscriber () -> typename std::enable_if< detail::is_on_next_of< T, detail::OnNextEmpty< T >>::value, subscriber< T, observer< T, detail::stateless_observer_tag, detail::OnNextEmpty< T >>>>::type
template<class T , class I >
auto	make_subscriber (const observer< T, I > &o) -> subscriber< T, observer< T, I >>
template<class T , class Observer >
auto	make_subscriber (const Observer &o) -> typename std::enable_if< is_observer< Observer >::value && !is_subscriber< Observer >::value, subscriber< T, Observer >>::type
template<class T , class OnNext >
auto	make_subscriber (const OnNext &on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext >>>::type
template<class T , class OnNext , class OnError >
auto	make_subscriber (const OnNext &on, const OnError &oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError >>>::type
template<class T , class OnNext , class OnCompleted >
auto	make_subscriber (const OnNext &on, const OnCompleted &oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted >>>::type
template<class T , class OnNext , class OnError , class OnCompleted >
auto	make_subscriber (const OnNext &on, const OnError &oe, const 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, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >>>::type
template<class T >
auto	make_subscriber (const composite_subscription &cs) -> subscriber< T, observer< T, detail::stateless_observer_tag, detail::OnNextEmpty< T >>>
template<class T , class I >
auto	make_subscriber (const composite_subscription &cs, const observer< T, I > &o) -> subscriber< T, observer< T, I >>
template<class T , class I >
auto	make_subscriber (const composite_subscription &cs, const subscriber< T, I > &s) -> subscriber< T, I >
template<class T , class Observer >
auto	make_subscriber (const composite_subscription &cs, const Observer &o) -> typename std::enable_if< !is_subscriber< Observer >::value && is_observer< Observer >::value, subscriber< T, Observer >>::type
template<class T , class OnNext >
auto	make_subscriber (const composite_subscription &cs, const OnNext &on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext >>>::type
template<class T , class OnNext , class OnError >
auto	make_subscriber (const composite_subscription &cs, const OnNext &on, const OnError &oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError >>>::type
template<class T , class OnNext , class OnCompleted >
auto	make_subscriber (const composite_subscription &cs, const OnNext &on, const OnCompleted &oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted >>>::type
template<class T , class OnNext , class OnError , class OnCompleted >
auto	make_subscriber (const composite_subscription &cs, const OnNext &on, const OnError &oe, const 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, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >>>::type
template<class T >
auto	make_subscriber (trace_id id) -> subscriber< T, observer< T, detail::stateless_observer_tag, detail::OnNextEmpty< T >>>
template<class T >
auto	make_subscriber (trace_id id, const composite_subscription &cs) -> subscriber< T, observer< T, detail::stateless_observer_tag, detail::OnNextEmpty< T >>>
template<class T , class I >
auto	make_subscriber (trace_id id, const observer< T, I > &o) -> subscriber< T, observer< T, I >>
template<class T , class I >
auto	make_subscriber (trace_id id, const composite_subscription &cs, const observer< T, I > &o) -> subscriber< T, observer< T, I >>
template<class T , class Observer >
auto	make_subscriber (trace_id id, const Observer &o) -> typename std::enable_if< is_observer< Observer >::value, subscriber< T, Observer >>::type
template<class T , class Observer >
auto	make_subscriber (trace_id id, const composite_subscription &cs, const Observer &o) -> typename std::enable_if< is_observer< Observer >::value, subscriber< T, Observer >>::type
template<class T , class OnNext >
auto	make_subscriber (trace_id id, const OnNext &on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext >>>::type
template<class T , class OnNext >
auto	make_subscriber (trace_id id, const composite_subscription &cs, const OnNext &on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext >>>::type
template<class T , class OnNext , class OnError >
auto	make_subscriber (trace_id id, const OnNext &on, const OnError &oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError >>>::type
template<class T , class OnNext , class OnError >
auto	make_subscriber (trace_id id, const composite_subscription &cs, const OnNext &on, const OnError &oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError >>>::type
template<class T , class OnNext , class OnCompleted >
auto	make_subscriber (trace_id id, const OnNext &on, const OnCompleted &oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted >>>::type
template<class T , class OnNext , class OnCompleted >
auto	make_subscriber (trace_id id, const composite_subscription &cs, const OnNext &on, const OnCompleted &oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted >>>::type
template<class T , class OnNext , class OnError , class OnCompleted >
auto	make_subscriber (trace_id id, const OnNext &on, const OnError &oe, const 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, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >>>::type
template<class T , class OnNext , class OnError , class OnCompleted >
auto	make_subscriber (trace_id id, const composite_subscription &cs, const OnNext &on, const OnError &oe, const 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, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >>>::type
template<class T , class OtherT , class OtherObserver , class I >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const observer< T, I > &o) -> subscriber< T, observer< T, I >>
template<class T , class OtherT , class OtherObserver , class I >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const observer< T, I > &o) -> subscriber< T, observer< T, I >>
template<class T , class OtherT , class OtherObserver , class Observer >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const Observer &o) -> typename std::enable_if< is_observer< Observer >::value, subscriber< T, Observer >>::type
template<class T , class OtherT , class OtherObserver , class Observer >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const Observer &o) -> typename std::enable_if< !is_subscription< Observer >::value && is_observer< Observer >::value, subscriber< T, Observer >>::type
template<class T , class OtherT , class OtherObserver , class OnNext >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const OnNext &on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const OnNext &on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnError >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const OnNext &on, const OnError &oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnError >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const OnNext &on, const OnError &oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnCompleted >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const OnNext &on, const OnCompleted &oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnCompleted >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const OnNext &on, const OnCompleted &oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnError , class OnCompleted >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const OnNext &on, const OnError &oe, const 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, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnError , class OnCompleted >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const OnNext &on, const OnError &oe, const 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, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >>>::type
template<class T , class OtherT , class OtherObserver , class I >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &, const composite_subscription &cs, const observer< T, I > &o) -> subscriber< T, observer< T, I >>
template<class T , class OtherT , class OtherObserver , class I >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &, trace_id id, const composite_subscription &cs, const observer< T, I > &o) -> subscriber< T, observer< T, I >>
template<class T , class OtherT , class OtherObserver , class Observer >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const composite_subscription &cs, const Observer &o) -> typename std::enable_if< is_observer< Observer >::value, subscriber< T, Observer >>::type
template<class T , class OtherT , class OtherObserver , class Observer >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const composite_subscription &cs, const Observer &o) -> typename std::enable_if< is_observer< Observer >::value, subscriber< T, Observer >>::type
template<class T , class OtherT , class OtherObserver , class OnNext >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const composite_subscription &cs, const OnNext &on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const composite_subscription &cs, const OnNext &on) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnError >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const composite_subscription &cs, const OnNext &on, const OnError &oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnError >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const composite_subscription &cs, const OnNext &on, const OnError &oe) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_error< OnError >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnCompleted >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const composite_subscription &cs, const OnNext &on, const OnCompleted &oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnCompleted >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const composite_subscription &cs, const OnNext &on, const OnCompleted &oc) -> typename std::enable_if< detail::is_on_next_of< T, OnNext >::value && detail::is_on_completed< OnCompleted >::value, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnError , class OnCompleted >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, const composite_subscription &cs, const OnNext &on, const OnError &oe, const 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, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >>>::type
template<class T , class OtherT , class OtherObserver , class OnNext , class OnError , class OnCompleted >
auto	make_subscriber (const subscriber< OtherT, OtherObserver > &scbr, trace_id id, const composite_subscription &cs, const OnNext &on, const OnError &oe, const 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, subscriber< T, observer< T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted >>>::type
template<class T , class Observer >
auto	make_subscriber (const subscriber< T, Observer > &scbr, const composite_subscription &cs) -> subscriber< T, Observer >
template<class T , class Observer >
auto	make_subscriber (const subscriber< T, Observer > &scbr, trace_id id, const composite_subscription &cs) -> subscriber< T, Observer >
template<class T , class Observer >
auto	make_subscriber (const subscriber< T, Observer > &scbr, trace_id id) -> subscriber< T, Observer >
bool	operator< (const subscription &lhs, const subscription &rhs)
bool	operator== (const subscription &lhs, const subscription &rhs)
bool	operator!= (const subscription &lhs, const subscription &rhs)
auto	make_subscription () -> subscription
template<class I >
auto	make_subscription (I &&i) -> typename std::enable_if<!is_subscription< I >::value &&!detail::is_unsubscribe_function< I >::value, subscription >::type
template<class Unsubscribe >
auto	make_subscription (Unsubscribe &&u) -> typename std::enable_if< detail::is_unsubscribe_function< Unsubscribe >::value, subscription >::type
bool	operator< (const composite_subscription &lhs, const composite_subscription &rhs)
bool	operator== (const composite_subscription &lhs, const composite_subscription &rhs)
bool	operator!= (const composite_subscription &lhs, const composite_subscription &rhs)
bool	operator== (const trace_id &lhs, const trace_id &rhs)
bool	operator!= (const trace_id &lhs, const trace_id &rhs)
bool	operator< (const trace_id &lhs, const trace_id &rhs)
bool	operator> (const trace_id &lhs, const trace_id &rhs)
std::ostream &	operator<< (std::ostream &os, const trace_id &id)
identity_one_worker	identity_test ()
synchronize_in_one_worker	synchronize_event_loop ()
synchronize_in_one_worker	synchronize_new_thread ()

Typedef Documentation

template<class... ObservableN>

using rxcpp::all_observables = typedef rxu::all_true_type<is_observable<ObservableN>...>

template<class Coordination , class DecayedCoordination = rxu::decay_t<Coordination>>

using rxcpp::coordination_tag_t = typedef typename DecayedCoordination::coordination_tag

template<class T , class... AN>

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

template<class Observable , class DecayedObservable = rxu::decay_t<Observable>>

using rxcpp::observable_tag_t = typedef typename DecayedObservable::observable_tag

template<class... ObservableN>

using rxcpp::observable_tags_t = typedef typename expand_observable_tags<rxu::types<ObservableN...>>::type

Function Documentation

identity_one_worker rxcpp::identity_current_thread ( )

inline

identity_one_worker rxcpp::identity_immediate ( )

inline

identity_one_worker rxcpp::identity_same_worker ( rxsc::worker  w )

inline

identity_one_worker rxcpp::identity_test ( )

inline

template<class T , class Source >

connectable_observable<T> rxcpp::make_dynamic_connectable_observable

(

Source &&

s

)

template<class K , class T , class Source >

grouped_observable< K, T > rxcpp::make_dynamic_grouped_observable

(

Source &&

s

)

template<class T , class Source >

observable< T > rxcpp::make_observable_dynamic

(

Source &&

s

)

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 T , class Observer >

auto rxcpp::make_subscriber

(

subscriber< T, Observer >

o

)

-> subscriber<T, Observer>

template<class T >

auto rxcpp::make_subscriber

(

)

-> typename std::enable_if< detail::is_on_next_of<T, detail::OnNextEmpty<T>>::value, subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>>::type

template<class T , class I >

auto rxcpp::make_subscriber

(

const observer< T, I > &

o

)

-> subscriber<T, observer<T, I>>

template<class T , class Observer >

auto rxcpp::make_subscriber

(

const Observer &

o

)

-> typename std::enable_if< is_observer<Observer>::value && !is_subscriber<Observer>::value, subscriber<T, Observer>>::type

template<class T , class OnNext >

auto rxcpp::make_subscriber

(

const OnNext &

on

)

-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type

template<class T , class OnNext , class OnError >

auto rxcpp::make_subscriber	(	const OnNext &	on,
		const OnError &	oe
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_error<OnError>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type

template<class T , class OnNext , class OnCompleted >

auto rxcpp::make_subscriber	(	const OnNext &	on,
		const OnCompleted &	oc
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_completed<OnCompleted>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type

template<class T , class OnNext , class OnError , class OnCompleted >

auto rxcpp::make_subscriber	(	const OnNext &	on,
		const OnError &	oe,
		const 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, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type

template<class T >

auto rxcpp::make_subscriber

(

const composite_subscription &

cs

)

-> subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>

template<class T , class I >

auto rxcpp::make_subscriber	(	const composite_subscription &	cs,
		const observer< T, I > &	o
	)		-> subscriber<T, observer<T, I>>

template<class T , class I >

auto rxcpp::make_subscriber	(	const composite_subscription &	cs,
		const subscriber< T, I > &	s
	)		-> subscriber<T, I>

template<class T , class Observer >

auto rxcpp::make_subscriber	(	const composite_subscription &	cs,
		const Observer &	o
	)		-> typename std::enable_if< !is_subscriber<Observer>::value && is_observer<Observer>::value, subscriber<T, Observer>>::type

template<class T , class OnNext >

auto rxcpp::make_subscriber	(	const composite_subscription &	cs,
		const OnNext &	on
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type

template<class T , class OnNext , class OnError >

auto rxcpp::make_subscriber	(	const composite_subscription &	cs,
		const OnNext &	on,
		const OnError &	oe
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_error<OnError>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type

template<class T , class OnNext , class OnCompleted >

auto rxcpp::make_subscriber	(	const composite_subscription &	cs,
		const OnNext &	on,
		const OnCompleted &	oc
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_completed<OnCompleted>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type

template<class T , class OnNext , class OnError , class OnCompleted >

auto rxcpp::make_subscriber	(	const composite_subscription &	cs,
		const OnNext &	on,
		const OnError &	oe,
		const 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, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type

template<class T >

auto rxcpp::make_subscriber

(

trace_id

id

)

-> subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>

template<class T >

auto rxcpp::make_subscriber	(	trace_id	id,
		const composite_subscription &	cs
	)		-> subscriber<T, observer<T, detail::stateless_observer_tag, detail::OnNextEmpty<T>>>

template<class T , class I >

auto rxcpp::make_subscriber	(	trace_id	id,
		const observer< T, I > &	o
	)		-> subscriber<T, observer<T, I>>

template<class T , class I >

auto rxcpp::make_subscriber	(	trace_id	id,
		const composite_subscription &	cs,
		const observer< T, I > &	o
	)		-> subscriber<T, observer<T, I>>

template<class T , class Observer >

auto rxcpp::make_subscriber	(	trace_id	id,
		const Observer &	o
	)		-> typename std::enable_if< is_observer<Observer>::value, subscriber<T, Observer>>::type

template<class T , class Observer >

auto rxcpp::make_subscriber	(	trace_id	id,
		const composite_subscription &	cs,
		const Observer &	o
	)		-> typename std::enable_if< is_observer<Observer>::value, subscriber<T, Observer>>::type

template<class T , class OnNext >

auto rxcpp::make_subscriber	(	trace_id	id,
		const OnNext &	on
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type

template<class T , class OnNext >

auto rxcpp::make_subscriber	(	trace_id	id,
		const composite_subscription &	cs,
		const OnNext &	on
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type

template<class T , class OnNext , class OnError >

auto rxcpp::make_subscriber	(	trace_id	id,
		const OnNext &	on,
		const OnError &	oe
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_error<OnError>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type

template<class T , class OnNext , class OnError >

auto rxcpp::make_subscriber	(	trace_id	id,
		const composite_subscription &	cs,
		const OnNext &	on,
		const OnError &	oe
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_error<OnError>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type

template<class T , class OnNext , class OnCompleted >

auto rxcpp::make_subscriber	(	trace_id	id,
		const OnNext &	on,
		const OnCompleted &	oc
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_completed<OnCompleted>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type

template<class T , class OnNext , class OnCompleted >

auto rxcpp::make_subscriber	(	trace_id	id,
		const composite_subscription &	cs,
		const OnNext &	on,
		const OnCompleted &	oc
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_completed<OnCompleted>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type

template<class T , class OnNext , class OnError , class OnCompleted >

auto rxcpp::make_subscriber	(	trace_id	id,
		const OnNext &	on,
		const OnError &	oe,
		const 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, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type

template<class T , class OnNext , class OnError , class OnCompleted >

auto rxcpp::make_subscriber	(	trace_id	id,
		const composite_subscription &	cs,
		const OnNext &	on,
		const OnError &	oe,
		const 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, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type

template<class T , class OtherT , class OtherObserver , class I >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const observer< T, I > &	o
	)		-> subscriber<T, observer<T, I>>

template<class T , class OtherT , class OtherObserver , class I >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const observer< T, I > &	o
	)		-> subscriber<T, observer<T, I>>

template<class T , class OtherT , class OtherObserver , class Observer >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const Observer &	o
	)		-> typename std::enable_if< is_observer<Observer>::value, subscriber<T, Observer>>::type

template<class T , class OtherT , class OtherObserver , class Observer >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const Observer &	o
	)		-> typename std::enable_if< !is_subscription<Observer>::value && is_observer<Observer>::value, subscriber<T, Observer>>::type

template<class T , class OtherT , class OtherObserver , class OnNext >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const OnNext &	on
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const OnNext &	on
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnError >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const OnNext &	on,
		const OnError &	oe
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_error<OnError>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnError >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const OnNext &	on,
		const OnError &	oe
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_error<OnError>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnCompleted >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const OnNext &	on,
		const OnCompleted &	oc
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_completed<OnCompleted>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnCompleted >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const OnNext &	on,
		const OnCompleted &	oc
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_completed<OnCompleted>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnError , class OnCompleted >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const OnNext &	on,
		const OnError &	oe,
		const 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, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnError , class OnCompleted >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const OnNext &	on,
		const OnError &	oe,
		const 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, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type

template<class T , class OtherT , class OtherObserver , class I >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	,
		const composite_subscription &	cs,
		const observer< T, I > &	o
	)		-> subscriber<T, observer<T, I>>

template<class T , class OtherT , class OtherObserver , class I >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	,
		trace_id	id,
		const composite_subscription &	cs,
		const observer< T, I > &	o
	)		-> subscriber<T, observer<T, I>>

template<class T , class OtherT , class OtherObserver , class Observer >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const composite_subscription &	cs,
		const Observer &	o
	)		-> typename std::enable_if< is_observer<Observer>::value, subscriber<T, Observer>>::type

template<class T , class OtherT , class OtherObserver , class Observer >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const composite_subscription &	cs,
		const Observer &	o
	)		-> typename std::enable_if< is_observer<Observer>::value, subscriber<T, Observer>>::type

template<class T , class OtherT , class OtherObserver , class OnNext >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const composite_subscription &	cs,
		const OnNext &	on
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const composite_subscription &	cs,
		const OnNext &	on
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnError >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const composite_subscription &	cs,
		const OnNext &	on,
		const OnError &	oe
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_error<OnError>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnError >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const composite_subscription &	cs,
		const OnNext &	on,
		const OnError &	oe
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_error<OnError>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnCompleted >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const composite_subscription &	cs,
		const OnNext &	on,
		const OnCompleted &	oc
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_completed<OnCompleted>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnCompleted >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const composite_subscription &	cs,
		const OnNext &	on,
		const OnCompleted &	oc
	)		-> typename std::enable_if< detail::is_on_next_of<T, OnNext>::value && detail::is_on_completed<OnCompleted>::value, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, detail::OnErrorEmpty, OnCompleted>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnError , class OnCompleted >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		const composite_subscription &	cs,
		const OnNext &	on,
		const OnError &	oe,
		const 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, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type

template<class T , class OtherT , class OtherObserver , class OnNext , class OnError , class OnCompleted >

auto rxcpp::make_subscriber	(	const subscriber< OtherT, OtherObserver > &	scbr,
		trace_id	id,
		const composite_subscription &	cs,
		const OnNext &	on,
		const OnError &	oe,
		const 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, subscriber<T, observer<T, detail::stateless_observer_tag, OnNext, OnError, OnCompleted>>>::type

template<class T , class Observer >

auto rxcpp::make_subscriber	(	const subscriber< T, Observer > &	scbr,
		const composite_subscription &	cs
	)		-> subscriber<T, Observer>

template<class T , class Observer >

auto rxcpp::make_subscriber	(	const subscriber< T, Observer > &	scbr,
		trace_id	id,
		const composite_subscription &	cs
	)		-> subscriber<T, Observer>

template<class T , class Observer >

auto rxcpp::make_subscriber	(	const subscriber< T, Observer > &	scbr,
		trace_id	id
	)		-> subscriber<T, Observer>

auto rxcpp::make_subscription ( ) -> subscription

inline

template<class I >

auto rxcpp::make_subscription

(

I &&

i

)

-> typename std::enable_if<!is_subscription<I>::value && !detail::is_unsubscribe_function<I>::value, subscription>::type

template<class Unsubscribe >

auto rxcpp::make_subscription

(

Unsubscribe &&

u

)

-> typename std::enable_if<detail::is_unsubscribe_function<Unsubscribe>::value, subscription>::type

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)...))

observe_on_one_worker rxcpp::observe_on_event_loop ( )

inline

observe_on_one_worker rxcpp::observe_on_new_thread ( )

inline

observe_on_one_worker rxcpp::observe_on_run_loop ( const rxsc::run_loop &  rl )

inline

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

bool rxcpp::operator!= ( const trace_id &  lhs, const trace_id &  rhs  )

inline

template<class T >

bool rxcpp::operator!= ( const dynamic_observable< T > &  lhs, const dynamic_observable< T > &  rhs  )

inline

template<class K , class T >

bool rxcpp::operator!= ( const dynamic_grouped_observable< K, T > &  lhs, const dynamic_grouped_observable< K, T > &  rhs  )

inline

bool rxcpp::operator!= ( const subscription &  lhs, const subscription &  rhs  )

inline

bool rxcpp::operator!= ( const composite_subscription &  lhs, const composite_subscription &  rhs  )

inline

template<class T , class SourceOperator >

bool rxcpp::operator!= ( const observable< T, SourceOperator > &  lhs, const observable< T, SourceOperator > &  rhs  )

inline

bool rxcpp::operator< ( const trace_id &  lhs, const trace_id &  rhs  )

inline

bool rxcpp::operator< ( const subscription &  lhs, const subscription &  rhs  )

inline

bool rxcpp::operator< ( const composite_subscription &  lhs, const composite_subscription &  rhs  )

inline

std::ostream& rxcpp::operator<< ( std::ostream &  os, const trace_id &  id  )

inline

bool rxcpp::operator== ( const trace_id &  lhs, const trace_id &  rhs  )

inline

template<class T >

bool rxcpp::operator== ( const dynamic_observable< T > &  lhs, const dynamic_observable< T > &  rhs  )

inline

template<class K , class T >

bool rxcpp::operator== ( const dynamic_grouped_observable< K, T > &  lhs, const dynamic_grouped_observable< K, T > &  rhs  )

inline

bool rxcpp::operator== ( const subscription &  lhs, const subscription &  rhs  )

inline

bool rxcpp::operator== ( const composite_subscription &  lhs, const composite_subscription &  rhs  )

inline

template<class T , class SourceOperator >

bool rxcpp::operator== ( const observable< T, SourceOperator > &  lhs, const observable< T, SourceOperator > &  rhs  )

inline

bool rxcpp::operator> ( const trace_id &  lhs, const trace_id &  rhs  )

inline

serialize_one_worker rxcpp::serialize_event_loop ( )

inline

serialize_one_worker rxcpp::serialize_new_thread ( )

inline

serialize_one_worker rxcpp::serialize_same_worker ( rxsc::worker  w )

inline

synchronize_in_one_worker rxcpp::synchronize_event_loop ( )

inline

synchronize_in_one_worker rxcpp::synchronize_new_thread ( )

inline

auto rxcpp::trace_activity ( ) -> decltype(rxcpp_trace_activity(trace_tag()))&

inline