使用改造在 mvvm 中处理 Rxjava 的错误

Question

我正在调用一个给出 Http 状态代码 400 的 API

这是我的网络绑定资源NoDb

public abstract class NetworkBoundResourceNoDb<RequestType> {
private Observable<Resource<RequestType>> result;
@MainThread
protected NetworkBoundResourceNoDb() {
Observable<Resource<RequestType>> source;
source = createCall()
.subscribeOn(Schedulers.io())
.doOnError(t -> onFetchFailed())
.observeOn(AndroidSchedulers.mainThread());
result = Observable.ambArray(source);
}

public Observable<Resource<RequestType>> getAsObservable() {return result;}
protected boolean onFetchFailed() {
return false;
}

@NonNull
@MainThread
protected abstract Observable<Resource<RequestType>> createCall();
}

这是 API 代码

@GET("api/content/count")
Observable<List<WordCountData>> wordCount();

这是存储库功能

fun wordCount(): Observable<Resource<List<WordCountData>>>? {
return object : NetworkBoundResourceNoDb<List<WordCountData>>() {
override fun createCall(): Observable<Resource<List<WordCountData>>> {
return courseApi.wordCount()
.flatMap { learntWords ->
Observable.just(
if (learntWords == null) Resource.error("", emptyList())
else Resource.success(learntWords)
)
}
}
}.asObservable
}

这是视图模型代码

private var wordCount = MutableLiveData<Resource<List<WordCountData>>>()
fun getWordCountLiveData() = wordCount
fun getWordCountList() {
courseRepository.wordCount()?.subscribe { resource -> getWordCountLiveData().postValue(resource) }
}

这是我的视图代码

private fun loadWordCount() {
crViewModel = ViewModelProviders.of(this, viewModelFactory).get(CrViewModel::class.java)
crViewModel.getWordCountLiveData().observe(this, androidx.lifecycle.Observer {
resource -> when {
resource.isLoading -> println("loading")
resource.data != null -> {
drawChart(resource.data)
}
else -> handleErrorResponse()
}
})
crViewModel.getWordCountList()
}

我需要传递 Http 状态代码才能查看。 我能够在存储库中的onFetchfailed中出现错误，同时使用可抛出参数实现它，但之后无法处理它

它给了我"io.reactivex.exceptions.OnErrorNotImplementException： HTTP 400"错误

请提前帮助我谢谢

Answer 1

伙计，你在 1 中提出了很多问题。

fun getWordCountList() {
courseRepository.wordCount()?.subscribe { resource -> getWordCountLiveData().postValue(resource) }
}

这是触发所有其他网络代码的代码块。 但是，此 lambda 只有一个成功参数，没有错误参数。添加第二个 lambda，并用偏执来包围它，以说明成功和失败：

.subscribe({
successResponse -> // handle success
}, 
{ error -> // handle error
})

所以，这至少应该照顾"OnErrorNotImplementException">

错误 400 通常意味着请求无效，和/或向请求传递了错误的参数集。我无法帮助您获得您提供给我们的大量信息，并且对您的服务器一无所知。

最后："我需要传递 Http 状态代码才能查看"。什么？？为什么？ 你的标题甚至提到了建筑！为什么您的视图层甚至关心来自网络调用的响应代码？

别这样。当然，您的视图"可以"知道响应代码，但这是视图层根本不应该知道的事情。

我希望这有所帮助。