RxJava при ошибке выполняет onErrorResumeNext (), но также предпринимает некоторые действия

Question

Во время итерации и извлечения веб-ответов цепочка останавливается при обнаружении ошибки.

Я использовал .onErrorResumeNext (Observable.empty ()) для продолжения итерации, но хочу также выполнить некоторую обработку ошибок.Как это можно сделать?

                    .getRepos()
                    .flatMap { itemList ->
                        //fetches all repos      
                        Observable.fromIterable(itemList)
                    }
                    .concatMapEager { githubItem ->
                        //fetches commits of each repos 
                        networkModule.getCommits().map { commitItem ->

                            dataBaseModule.insertRepo(commitItem)
                        }.onErrorResumeNext(Observable.empty()) 
  //here I want to take some action instead of just passing an empty observable
                    }

Answer 1

Вы можете использовать оператор doOnError() непосредственно перед onErrorResumeNext() для выполнения действия.

...
.doOnError( error -> {} )
.onErrorResumeNext( Observable.empty() )
...