Error 발생 시에도 계속 처리 방법

안녕하세요. 강의 잘 수강중인 수강생입니다.

받아온 리스트를 flatMap을 통해 각각 observable 작업을 만들고 순차적으로 실행할 때

중간에 하나가 실패하더라도 계속 그 다음 Observable로 넘어가도록 하는 방법은 없나요?

아니면 혹시 좋은 처리 방법이 있을지요.

try-catch를 flatMap 내부 블럭에서 쓰기엔 rxJava스럽지 않은 방법이고...

onErrorReturnNext같은 함수를 쓰기도 좀 애매하네요.

가운데 fetchData() 부분만 봐주시면 될 것 같습니다

import io.reactivex.Completable
import io.reactivex.Observable
import io.reactivex.Single
import org.mockito.ArgumentMatchers.anyInt
import org.mockito.Mockito
import org.mockito.kotlin.eq
import org.mockito.kotlin.given
import org.mockito.kotlin.whenever
import java.lang.Exception

val db = mutableListOf<String>()

fun <T : Any> safeEq(value: T): T = eq(value) ?: value

fun main() {
    val fakeSentenceMaker: SentenceMaker = Mockito.mock(SentenceMaker::class.java)
    whenever(fakeSentenceMaker.getNonLuckySentence(anyInt()))
        .thenCallRealMethod()
    whenever(fakeSentenceMaker.getLuckySentence())
        .thenCallRealMethod()
    given(fakeSentenceMaker.getNonLuckySentence(safeEq(4)))
        .willAnswer{ throw Exception("실패!") }

    val repository = Repository(fakeSentenceMaker)

    repository.fetchData()
        .subscribe({
            println("성공 >> ")
        }, {
            println("실패 >> $it")
        })

    Thread.sleep(1000)

    db.also {
        println(it)
    }
}

class Repository(
    private val sentenceMaker: SentenceMaker
) {
    private fun getList(): Single<List<Int>> {
        return Single.just(listOf(1, 2, 3, 4, 5, 6, 7, 8))
    }

    fun fetchData(): Completable {
        return getList()
            .flatMapObservable { Observable.fromIterable(it) }
            .flatMap {
                println("현재 데이터 >> $it")
                if (it == 7) {
                    sentenceMaker.getLuckySentence()
                } else {
                    sentenceMaker.getNonLuckySentence(it)
                }
            }
 //           .onErrorResumeNext(Observable.just("Error!"))
            .flatMapCompletable {
                println("before emit >> $it")
                saveData(it)
            }
    }

    fun saveData(data: String): Completable {
        return Completable.create { emitter ->
            println("emit >> $data")
            db.add(data)
            emitter.onComplete()
        }
    }

}

class SentenceMaker {
    fun getLuckySentence(): Observable<String> {
        val luckySentence = "7은 행운의 숫자입니다"

        return Observable.just(luckySentence)
    }

    fun getNonLuckySentence(num: Int): Observable<String> {
        val nonLuckySentence = "${num}은 행운의 숫자가 아닙니다"
        return Observable.just(nonLuckySentence)
    }
}