Searched refs:on_error (Results 1 – 5 of 5) sorted by relevance
57 E&& on_error) { in SubscribeAsync() argument63 on_error=std::forward<E>(on_error)]() mutable { in SubscribeAsync()68 std::forward<decltype(on_error)>(on_error)); in SubscribeAsync()
263 dest.on_error( in EmitFromCommandWithArgv()271 dest.on_error( in EmitFromCommandWithArgv()315 dest.on_error( in EmitFromCommandWithArgv()341 dest.on_error( in EmitFromCommandWithArgv()359 dest.on_error( in EmitFromCommandWithArgv()
110 dest.on_error(rxcpp::util::make_error_ptr( in EmitInodes()
255 history_id_subscriber_->on_error(rxcpp::util::make_error_ptr( in OnNewEvent()622 history_id_subscriber_->on_error(rxcpp::util::make_error_ptr( in RecordDbLaunchHistory()
443 dest.on_error(rxcpp::util::make_error_ptr(StateChangedError{msg})); in EmitError()