5 #if !defined(RXCPP_RX_TRACE_HPP) 6 #define RXCPP_RX_TRACE_HPP 17 static std::atomic<unsigned long>
id(0xB0000000);
24 return lhs.
id == rhs.
id;
31 if ((lhs.
id & 0xF0000000) != (rhs.
id & 0xF0000000)) std::terminate();
32 return lhs.
id < rhs.
id;
39 return os << std::hex <<
id.id << std::dec;
44 template<
class Worker,
class Schedulable>
46 template<
class Worker>
48 template<
class Worker,
class When,
class Schedulable>
50 template<
class Worker>
53 template<
class Schedulable>
55 template<
class Schedulable>
57 template<
class Schedulable>
60 template<
class Observable,
class Subscriber>
62 template<
class Observable>
65 template<
class SubscriberFrom,
class SubscriberTo>
66 inline void connect(
const SubscriberFrom&,
const SubscriberTo&) {}
68 template<
class OperatorSource,
class OperatorChain,
class Subscriber,
class SubscriberLifted>
69 inline void lift_enter(
const OperatorSource&,
const OperatorChain&,
const Subscriber&,
const SubscriberLifted&) {}
70 template<
class OperatorSource,
class OperatorChain>
71 inline void lift_return(
const OperatorSource&,
const OperatorChain&) {}
73 template<
class SubscriptionState>
75 template<
class SubscriptionState>
78 template<
class SubscriptionState,
class Subscription>
80 template<
class SubscriptionState>
83 template<
class SubscriptionState,
class WeakSubscription>
85 template<
class SubscriptionState>
88 template<
class Subscriber>
91 template<
class Subscriber,
class T>
93 template<
class Subscriber>
96 template<
class Subscriber>
98 template<
class Subscriber>
101 template<
class Subscriber>
103 template<
class Subscriber>
void action_recurse(const Schedulable &)
Definition: rx-trace.hpp:58
Definition: rx-trace.hpp:42
void schedule_enter(const Worker &, const Schedulable &)
Definition: rx-trace.hpp:45
bool operator>(const trace_id &lhs, const trace_id &rhs)
Definition: rx-trace.hpp:34
Definition: rx-all.hpp:26
void subscribe_return(const Observable &)
Definition: rx-trace.hpp:63
bool operator<(const subscription &lhs, const subscription &rhs)
Definition: rx-subscription.hpp:186
void subscription_add_return(const SubscriptionState &)
Definition: rx-trace.hpp:81
void create_subscriber(const Subscriber &)
Definition: rx-trace.hpp:89
void subscription_remove_return(const SubscriptionState &)
Definition: rx-trace.hpp:86
void schedule_return(const Worker &)
Definition: rx-trace.hpp:47
void schedule_when_return(const Worker &)
Definition: rx-trace.hpp:51
void lift_enter(const OperatorSource &, const OperatorChain &, const Subscriber &, const SubscriberLifted &)
Definition: rx-trace.hpp:69
auto rxcpp_trace_activity(...) -> rxcpp::trace_noop
Definition: rx-trace.hpp:14
std::ostream & operator<<(std::ostream &os, const trace_id &id)
Definition: rx-trace.hpp:38
void on_error_return(const Subscriber &)
Definition: rx-trace.hpp:99
void on_next_enter(const Subscriber &, const T &)
Definition: rx-trace.hpp:92
unsigned long id
Definition: rx-trace.hpp:20
void subscription_add_enter(const SubscriptionState &, const Subscription &)
Definition: rx-trace.hpp:79
void subscription_remove_enter(const SubscriptionState &, const WeakSubscription &)
Definition: rx-trace.hpp:84
void on_completed_enter(const Subscriber &)
Definition: rx-trace.hpp:102
bool operator!=(const dynamic_grouped_observable< K, T > &lhs, const dynamic_grouped_observable< K, T > &rhs)
Definition: rx-grouped_observable.hpp:103
void action_return(const Schedulable &)
Definition: rx-trace.hpp:56
bool operator==(const dynamic_grouped_observable< K, T > &lhs, const dynamic_grouped_observable< K, T > &rhs)
Definition: rx-grouped_observable.hpp:99
void unsubscribe_return(const SubscriptionState &)
Definition: rx-trace.hpp:76
void lift_return(const OperatorSource &, const OperatorChain &)
Definition: rx-trace.hpp:71
void schedule_when_enter(const Worker &, const When &, const Schedulable &)
Definition: rx-trace.hpp:49
Definition: rx-trace.hpp:107
void action_enter(const Schedulable &)
Definition: rx-trace.hpp:54
static trace_id make_next_id_subscriber()
Definition: rx-trace.hpp:16
void on_next_return(const Subscriber &)
Definition: rx-trace.hpp:94
void subscribe_enter(const Observable &, const Subscriber &)
Definition: rx-trace.hpp:61
void on_error_enter(const Subscriber &, const std::exception_ptr &)
Definition: rx-trace.hpp:97
void on_completed_return(const Subscriber &)
Definition: rx-trace.hpp:104
void unsubscribe_enter(const SubscriptionState &)
Definition: rx-trace.hpp:74
void connect(const SubscriberFrom &, const SubscriberTo &)
Definition: rx-trace.hpp:66