Home	Sort by relevance Sort by last modified time

Full Search Definition Symbol File Path History   | | Help

    Searched defs:on_error (Results 1 - 25 of 39) sorted by null

1 2

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
rx-repeat.hpp	19 If the source observable calls on_error, repeat stops: 50 static inline void on_error(State& state, rxu::error_ptr& e) { function in struct:rxcpp::operators::detail::repeat::event_handlers 51 state->out.on_error(e);
rx-retry.hpp	13 \return An observable that mirrors the source observable, resubscribing to it if it calls on_error up to a specified number of retries. 46 static inline void on_error(State& state, rxu::error_ptr& e) { function in struct:rxcpp::operators::detail::retry::event_handlers 50 state->out.on_error(e);
rx-tap.hpp	7 \brief inspect calls to on_next, on_error and on_completed. 15 \note If an on_error method is not supplied the observer will ignore errors rather than call std::terminate() 95 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::tap::tap_observer 96 out.on_error(e); 97 dest.on_error(e);
rx-all.hpp	86 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::all::all_observer 87 dest.on_error(e);
rx-any.hpp	93 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::any::any_observer 94 dest.on_error(e);
rx-distinct.hpp	64 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::distinct::distinct_observer 65 dest.on_error(e);
rx-distinct_until_changed.hpp	77 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::distinct_until_changed::distinct_until_changed_observer 78 dest.on_error(e);
rx-element_at.hpp	80 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::element_at::element_at_observer 81 dest.on_error(e); 85 dest.on_error(rxu::make_error_ptr(std::range_error("index is out of bounds")));
rx-filter.hpp	82 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::filter::filter_observer 83 dest.on_error(e);
rx-finally.hpp	73 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::finally::finally_observer 74 dest.on_error(e);
rx-ignore_elements.hpp	59 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::ignore_elements::ignore_elements_observer 60 dest.on_error(e);
rx-map.hpp	80 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::map::map_observer 81 dest.on_error(e);
rx-on_error_resume_next.hpp	78 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::on_error_resume_next::on_error_resume_next_observer
rx-pairwise.hpp	70 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::pairwise::pairwise_observer 71 dest.on_error(e);
rx-skip_while.hpp	78 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::skip_while::skip_while_observer 79 dest.on_error(e);
rx-switch_if_empty.hpp	79 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::switch_if_empty::switch_if_empty_observer 80 dest.on_error(std::move(e));
rx-take_while.hpp	76 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::take_while::take_while_observer 77 dest.on_error(e);
rx-timestamp.hpp	81 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::timestamp::timestamp_observer 82 dest.on_error(e);
rx-buffer_count.hpp	99 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::buffer_count::buffer_count_observer 100 dest.on_error(e);
rx-delay.hpp	134 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::delay::delay_observer 137 localState->dest.on_error(e);
rx-time_interval.hpp	87 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::time_interval::time_interval_observer 88 dest.on_error(e);
rx-window.hpp	106 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::window::window_observer 108 s.get_subscriber().on_error(e); 110 dest.on_error(e);
rx-window_toggle.hpp	178 // on_error 180 localState->dest.on_error(e); 188 // on_error 190 localState->dest.on_error(e); 221 void on_error(rxu::error_ptr e) const { function in struct:rxcpp::operators::detail::window_toggle::window_toggle_observer 225 s.get_subscriber().on_error(e); 227 localState->dest.on_error(e);
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
lift.cpp	37 dest.on_error(rxu::current_exception()); 44 void on_error(rxu::error_ptr e) const { function in struct:detail::liftfilter::filter_observer 45 dest.on_error(e); 251 RXCPP_TRY {pass = predicate(n);} RXCPP_CATCH(...){dest.on_error(rxu::current_exception());}; 254 [=](rxu::error_ptr e){dest.on_error(e);},
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
rx-subscriber.hpp	59 that->destination.on_error(std::move(ex)); 80 that->destination.on_error(std::move(ex)); 183 void on_error(rxu::error_ptr e) const { function in class:rxcpp::subscriber     [all...]

Completed in 1170 milliseconds

1 2