Home
last modified time | relevance | path

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

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-take_until.hpp161 auto selectedSinkTrigger = on_exception( in on_subscribe() local
164 if (selectedSinkTrigger.empty()) { in on_subscribe()
167 trigger->subscribe(std::move(selectedSinkTrigger.get())); in on_subscribe()
Drx-skip_until.hpp158 auto selectedSinkTrigger = on_exception( in on_subscribe() local
161 if (selectedSinkTrigger.empty()) { in on_subscribe()
164 trigger->subscribe(std::move(selectedSinkTrigger.get())); in on_subscribe()