Home
last modified time | relevance | path

Searched refs:selectedProducer (Results 1 – 6 of 6) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/sources/
Drx-timer.hpp87 auto selectedProducer = on_exception( in on_subscribe() local
90 if (selectedProducer.empty()) { in on_subscribe()
94 controller.schedule(initial.when, selectedProducer.get()); in on_subscribe()
Drx-error.hpp82 auto selectedProducer = on_exception( in on_subscribe() local
85 if (selectedProducer.empty()) { in on_subscribe()
88 controller.schedule(selectedProducer.get()); in on_subscribe()
Drx-range.hpp103 auto selectedProducer = on_exception( in on_subscribe() local
106 if (selectedProducer.empty()) { in on_subscribe()
110 controller.schedule(selectedProducer.get()); in on_subscribe()
Drx-interval.hpp86 auto selectedProducer = on_exception( in on_subscribe() local
89 if (selectedProducer.empty()) { in on_subscribe()
93 controller.schedule_periodically(initial.initial, initial.period, selectedProducer.get()); in on_subscribe()
Drx-iterate.hpp144 auto selectedProducer = on_exception( in on_subscribe() local
147 if (selectedProducer.empty()) { in on_subscribe()
150 controller.schedule(selectedProducer.get()); in on_subscribe()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-subscribe_on.hpp132 auto selectedProducer = on_exception( in on_subscribe() local
135 if (selectedProducer.empty()) { in on_subscribe()
139 controller.schedule(selectedProducer.get()); in on_subscribe()