android - RX如何根据错误类型返回Throwable或Object

Question

我有一个返回Observable的方法。在这种情况下，如果发生错误，我需要检查错误类型，对于某些特定的错误，我需要返回MyObject而不是错误。
例:

    override fun getSomething(param: String): Observable<State> {
        return someInterface.getSingleResult(param)
            .flatMapObservable {
                when(something) {
                    true -> {
                        Observable.just(State.ACTIVE)
                    }
                    false -> {
                        Observable.just(State.PAUSED)
                    }
                }
            }
            .onErrorReturn {
                 if(it is Something) {
                      State.INACTIVE
                 } else {
//                    returns Throwable  <- don;t know how to handle this
                 } 
            } 
    }

Answer 1

我不确定我是否正确，但是以下内容对您有用吗？

.onErrorResumeNext {
    if (it is Something) {
        Observable.just(State.INACTIVE)
    } else {
        Observable.error(it)
    }
}

fun testObservable(): Observable<Int> {
    return Observable.just(1, 2, 3)
            .onErrorResumeNext { error: Throwable ->
                if (error is IllegalArgumentException) {
                    Observable.just(0)
                } else {
                    Observable.error(error)
                }
            }
}