MVVM RXAndroid 无法在后台线程上调用 setValue

Question

在我的应用程序中，我请求 json 来填充 recyclerview，首先在 init kotlin viewmodel 中它总是成功，但是当我想在 timer.schedule 方法中再次请求时，它会转到一次性订阅中的 onError 方法，这里是绑定在 xml 视图中的 Edittext 的 onTextChange :

fun onSearchTextChanged(text: CharSequence) {
    if (text.isNotEmpty()) {
        if (myTimer != null) {
            myTimer!!.cancel()
        }

        myTimer = Timer()
        myTimer!!.schedule(object : TimerTask() {
            override fun run() {
                loadMovies(text.toString(), 1)
            }

        }, 1000)
    } else {
        if (myTimer != null) {
            myTimer!!.cancel()
        }
    }
}

这是我的请求方法：

fun loadMovies(searchText: String, pageNumber: Int) {
    subscription = searchApi.getSearch(API_KEY, searchText, pageNumber)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .doOnSubscribe { onRetrieveMoviesListStart() }
        .doOnTerminate { onRetrieveMoviesListFinish() }
        .subscribe(
            { result -> onRetrieveMoviesListSuccess(result) },
            { err -> onRetrieveMoviesListError(err) })
}

private fun onRetrieveMoviesListStart() {
    loadingVisibility.value = View.VISIBLE
    Timber.d("started")
}

private fun onRetrieveMoviesListFinish() {
    loadingVisibility.value = View.GONE
    Timber.d("finished")
}

private fun onRetrieveMoviesListSuccess(search: Search) {
    Timber.d(search.toString())
    movieListAdapter.updateMoviesList(search.Search)
    movieEvent.value = MovieEvent.ANIMATE_RECYCLER
}

private fun onRetrieveMoviesListError(err: Throwable) {
    Timber.e(err)
}

这是 viewModel class 声明：

@Inject
lateinit var searchApi: SearchApi

val movieListAdapter: MovieListAdapter = MovieListAdapter()
private var myTimer: Timer? = null

private val movieEvent = SingleLiveEvent<MovieEvent>()
private lateinit var subscription: Disposable
val loadingVisibility: MutableLiveData<Int> = MutableLiveData()

init {
    loadMovies("someText", 1)
}

我该怎么办？

Answer 1

您在 ViewModel init 中对 loadMovies 的初始调用来自 main/ui 线程。 timertask 对 loadMovies 的调用来自后台线程。现在我对 rx 没有太多经验，但问题似乎与 livedata 有关。

您正在主线程上进行观察，这对于成功和错误方法来说很好。您的问题似乎是从后台线程调用的 onRetrieveMoviesListStart() 和 onRetrieveMoviesListFinish()。

livedata的值setter只能从主线程调用，要从后台线程设置值需要调用postValue。

像这样改变你的两个 methods/functions 应该可以解决问题：

private fun onRetrieveMoviesListStart() { 
    loadingVisibility.postValue(View.VISIBLE)
    Timber.d("started")
} 
private fun onRetrieveMoviesListFinish() {
    loadingVisibility.postValue(View.GONE)
    Timber.d("finished")
}

MVVM RXAndroid 无法在后台线程上调用 setValue

MVVM RXAndroid Cannot invoke setValue on a background thread

android

rx-android

retrofit2