Comment éviter l'arrêt observable après onError

Question

Après onError, mon observable cesse de fonctionner. Comment puis-je éviter cela?

Voici mon autocomplete Code observable et abonnement:

public void subscribeAutoComplete() { 
    autoSubscription = RxTextView.textChangeEvents(clearableEditText) 
      .skip(1) 
      .map(textViewTextChangeEvent -> textViewTextChangeEvent.text().toString()) 
      .filter(s -> s.length() > 2) 
      .debounce(400, TimeUnit.MILLISECONDS) 
      .flatMap(text -> autoCompleteService.getAutoCompleteTerms(text) 
       .subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread())) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .subscribe(new Subscriber<List<String>>() { 
       @Override 
       public void onCompleted() { 
        Log.d("rx", "oncomplete"); 
       } 

       @Override 
       public void onError(Throwable t) { 
        Log.e("rx", t.toString()); 
       } 

       @Override 
       public void onNext(List<String> strings) { 

        autoAdapter = new ArrayAdapter<>(MainActivity.this, 
           android.R.layout.simple_dropdown_item_1line, strings); 
        clearableEditText.setAdapter(autoAdapter); 
        clearableEditText.showDropDown(); 

       } 
      }); 

    compositeSubscriptions.add(autoSubscription); 
} 

Answer 1

Il est simple, il suffit d'ignorer les erreurs:

autoCompleteService.getAutoCompleteTerms(text).onErrorResumeNext(Observable.empty()) 

Notez que cela est potentiellement dangereux, comme vous ignorez tous les erreurs; dans ce cas, c'est probablement OK, mais faites attention à ne pas trop utiliser cela.