Home
last modified time | relevance | path

Searched refs:selectedSink (Results 1 – 11 of 11) sorted by relevance

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-window_toggle.hpp185 auto selectedSink = localState->coordinator.out(sink); in window_toggle_observer() local
186 source.subscribe(std::move(selectedSink)); in window_toggle_observer()
196 auto selectedSink = on_exception( in window_toggle_observer() local
199 if (selectedSink.empty()) { in window_toggle_observer()
202 source->subscribe(std::move(selectedSink.get())); in window_toggle_observer()
Drx-switch_on_next.hpp185 auto selectedSink = on_exception( in on_subscribe() local
188 if (selectedSink.empty()) { in on_subscribe()
192 source->subscribe(std::move(selectedSink.get())); in on_subscribe()
Drx-merge.hpp201 auto selectedSink = on_exception( in on_subscribe() local
204 if (selectedSink.empty()) { in on_subscribe()
207 source->subscribe(std::move(selectedSink.get())); in on_subscribe()
Drx-merge_delay_error.hpp215 auto selectedSink = on_exception( in on_subscribe() local
218 if (selectedSink.empty()) { in on_subscribe()
221 source->subscribe(std::move(selectedSink.get())); in on_subscribe()
Drx-amb.hpp209 auto selectedSink = on_exception( in on_subscribe() local
212 if (selectedSink.empty()) { in on_subscribe()
215 source->subscribe(std::move(selectedSink.get())); in on_subscribe()
Drx-concat.hpp220 auto selectedSink = on_exception( in on_subscribe() local
223 if (selectedSink.empty()) { in on_subscribe()
226 source->subscribe(std::move(selectedSink.get())); in on_subscribe()
Drx-with_latest_from.hpp186 auto selectedSink = on_exception( in subscribe_one() local
189 if (selectedSink.empty()) { in subscribe_one()
192 source->subscribe(std::move(selectedSink.get())); in subscribe_one()
Drx-combine_latest.hpp186 auto selectedSink = on_exception( in subscribe_one() local
189 if (selectedSink.empty()) { in subscribe_one()
192 source->subscribe(std::move(selectedSink.get())); in subscribe_one()
Drx-zip.hpp218 auto selectedSink = on_exception( in subscribe_one() local
221 if (selectedSink.empty()) { in subscribe_one()
224 source->subscribe(std::move(selectedSink.get())); in subscribe_one()
Drx-flat_map.hpp227 auto selectedSink = on_exception( in on_subscribe() local
230 if (selectedSink.empty()) { in on_subscribe()
234 source->subscribe(std::move(selectedSink.get())); in on_subscribe()
Drx-concat_map.hpp259 auto selectedSink = on_exception( in on_subscribe() local
262 if (selectedSink.empty()) { in on_subscribe()
265 source->subscribe(std::move(selectedSink.get())); in on_subscribe()