Home
last modified time | relevance | path

Searched refs:selectedDrain (Results 1 – 2 of 2) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-synchronize.hpp84 auto selectedDrain = on_exception( in ensure_processing() local
87 if (selectedDrain.empty()) { in ensure_processing()
92 processor.schedule(lifetime, selectedDrain.get()); in ensure_processing()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-observe_on.hpp162 auto selectedDrain = on_exception( in ensure_processing() local
165 if (selectedDrain.empty()) { in ensure_processing()
175 processor.schedule(selectedDrain.get()); in ensure_processing()