Home
last modified time | relevance | path

Searched refs:trace_activity (Results 1 – 8 of 8) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/examples/pythagorian/
Dmain.cpp142 …: " << rxcpp::trace_activity().onnexts << ", onerrors: " << rxcpp::trace_activity().onerrors << ",… in wmain()
143 …std::cout << "subscribes: " << rxcpp::trace_activity().subscribes << ", lifts: " << rxcpp::trace_a… in wmain()
144 …ibes: " << rxcpp::trace_activity().unsubscribes << ", adds: " << rxcpp::trace_activity().adds << "… in wmain()
145 …std::cout << "schedules: " << rxcpp::trace_activity().schedules << ", schedulewhens: " << rxcpp::t… in wmain()
146 …std::cout << "actions: " << rxcpp::trace_activity().actions << ", recurses: " << rxcpp::trace_acti… in wmain()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-subscriber.hpp40 trace_activity().on_next_return(*that); in ~nextdetacher()
52 trace_activity().on_next_enter(*that, u); in operator ()()
58 trace_activity().on_error_enter(*that, ex); in operator ()()
60 trace_activity().on_error_return(*that); in operator ()()
71 trace_activity().on_error_return(*that); in ~errordetacher()
79 trace_activity().on_error_enter(*that, ex); in operator ()()
89 trace_activity().on_completed_return(*that); in ~completeddetacher()
97 trace_activity().on_completed_enter(*that); in operator ()()
143 trace_activity().create_subscriber(*this); in subscriber()
524 trace_activity().connect(r, scbr); in make_subscriber()
[all …]
Drx-scheduler.hpp708 trace_activity().action_enter(s); in operator ()()
719 trace_activity().action_recurse(s); in operator ()()
721 trace_activity().action_return(s); in operator ()()
807 trace_activity().schedule_enter(*inner.get(), scbl); in schedule()
809 trace_activity().schedule_return(*inner.get()); in schedule()
814 trace_activity().schedule_enter(*inner.get(), rescbl); in schedule_rebind()
816 trace_activity().schedule_return(*inner.get()); in schedule_rebind()
826 trace_activity().schedule_when_enter(*inner.get(), when, scbl); in schedule()
828 trace_activity().schedule_when_return(*inner.get()); in schedule()
833 trace_activity().schedule_when_enter(*inner.get(), when, rescbl); in schedule_rebind()
[all …]
Drx-subscription.hpp98 trace_activity().unsubscribe_enter(*this); in unsubscribe()
100 trace_activity().unsubscribe_return(*this); in unsubscribe()
515 trace_activity().subscription_add_enter(*that, s); in add()
517 trace_activity().subscription_add_return(*that); in add()
529 trace_activity().subscription_remove_enter(*that, w); in remove()
531 trace_activity().subscription_remove_return(*that); in remove()
Drx-predef.hpp15 inline auto trace_activity() -> decltype(rxcpp_trace_activity(trace_tag()))& { in trace_activity() function
Drx-observable.hpp511 trace_activity().subscribe_enter(*this, o); in detail_subscribe()
514 trace_activity().subscribe_return(*this); in detail_subscribe()
529 trace_activity().subscribe_return(*this); in detail_subscribe()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-lift.hpp77 trace_activity().lift_enter(source, chain, o, lifted); in on_subscribe()
79 trace_activity().lift_return(source, chain); in on_subscribe()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-subject.hpp133 trace_activity().connect(sf, o); in add()