android - 如何使用 RXJava 调用的响应结果作为另一个 RXJava 函数内 if 语句的条件？

Question

我正在进行 2 个 RX 调用，这些调用相互嵌套且相互依赖。服务器存在问题(由于各种原因目前无法解决)，该问题在第二个嵌套调用中返回错误。

在这个问题得到解决之前，我需要确保如果第二次调用返回错误，则第一次调用的结果也会被丢弃。现在，整个迭代过程在任何这些错误响应发生时都会停止，因此我的目标是跳过它们。

这是我当前的调用结构:

 fun getAllDynamicUtterances(module: String) {

    var uttList: ArrayList<DynamicUtterance>? = ArrayList()
    rxSubs?.add(
        repository.getDynamicUtterances(module).map{res ->
            res.uttSets.forEach {utt ->
                    utt.module = res.module!!
                    utt.transferInputValues()
                    utt.generateDefaultFlatTree()
                    uttList?.add(utt)
                    insertDynamicUtterance(utt)
                    repository.updateDynamicUtteranceView(utt).blockingForEach {
                        utt.assignSelectionStrings(it)
                        repository.storeDynamicUttPieces(utt.inputUttPieces)
                        utt.uttLinearisations = it.linearisations
                        updateDynamicUtterance(utt)
                    }
            }
        }.subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread()).subscribe ({
                allDynamicUtterances?.postValue(uttList)
            },{
                Log.e("errorHandle",it.toString())
            })
    )
}

我的想法是包含一个 if 语句，该语句几乎在继续之前“查看”第二个调用，但我不确定如何进行。这是我到目前为止所想出的来表达我的想法:

fun getAllDynamicUtterances(module: String) {

    var uttList: ArrayList<DynamicUtterance>? = ArrayList()
    rxSubs?.add(
        repository.getDynamicUtterances(module).map{res ->
            res.uttSets.forEach {utt ->
                    utt.module = res.module!!
                    utt.transferInputValues()
                    utt.generateDefaultFlatTree()
                if (doesNotReturnError(utt)){ // <- add this
                    uttList?.add(utt)
                    insertDynamicUtterance(utt)
                    repository.updateDynamicUtteranceView(utt).blockingForEach {
                        utt.assignSelectionStrings(it)
                        repository.storeDynamicUttPieces(utt.inputUttPieces)
                        utt.uttLinearisations = it.linearisations
                        updateDynamicUtterance(utt)
                    }
                }
            }
        }.subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread()).subscribe ({
                allDynamicUtterances?.postValue(uttList)
            },{
                Log.e("errorHandle",it.toString())
            })
    )
}

然后添加这个函数，或者一个执行我在任何情况下试图实现的功能的函数。

private fun doesNotReturnError(utt: DynamicUtterance): Boolean{
   rxSubs?.add(
       repository.updateDynamicUtteranceView(utt).subscribeOn(Schedulers.io())
           .observeOn(AndroidSchedulers.mainThread())
           .subscribe({
             //cant put a return here :(
           }, {
               Timber.e(it)
           })
   )
    //returning over here will return nothing wont it? 
}

我欢迎有关如何改进我的 getAllDynamicUtterances 功能的评论

Answer 1

听起来像是 flatMap 而不是 map 的工作。

repository.getDynamicUtterances(module).flatMap{res ->
            res.uttSets.forEach {utt ->
                    utt.module = res.module!!
                    utt.transferInputValues()
                    utt.generateDefaultFlatTree()
            return if (doesNotReturnError(utt)){ // <- add this
                    uttList?.add(utt)
                    insertDynamicUtterance(utt)

                    repository.updateDynamicUtteranceView(utt).doOnNext {
                        utt.assignSelectionStrings(it)
                        repository.storeDynamicUttPieces(utt.inputUttPieces)
                        utt.uttLinearisations = it.linearisations
                        updateDynamicUtterance(utt)
                    }
                } else {
                   Observable.error(utt.getError())
                }
            }