java - RxJava - 等待异步任务然后调用 Api

Question

尝试获取lastLocation并在完成后调用 api。但是不知何故，一旦获得位置，我的 api 调用总是在运行mainThread，所以我遇到了异常：

android.io.NetworkOnMainThreadException

这是我的位置观察员：

fun getLocation(): Single<Location> {
        return Single.create<Location> { subscriber ->
            fusedLocationClient.lastLocation.addOnSuccessListener {
                if (it != null) {
                    subscriber.onSuccess(it)
                } else {
                    subscriber.onError(Exception("No location"))
                }
            }
        }
    }

进行一些转换的代码

val locationObserver = getLocation()
observables.add(locationObserver.flatMap { _ -> sendDataToServer(data)})

观察者

Single.zip(observables) { args1 -> args1 }.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe({
            Timber.i("Success")

        }, {
            Timber.i("Error %s", observables.size, it.localizedMessage)
            it.printStackTrace()
        })

我已经设置subscribeOn，所以它不应该打开mainThread，但看起来好像错过了什么。

发现如果我将使用类似的东西Single.just("One").flatMap{ ... }会正常工作并将在非主线程上执行。

跟getLocation功能有关系吗？

标签： javaandroidkotlinrx-javarx-java2

Answer 1

subscribeOn、observeOn、subscribe和 转换的顺序很重要。显然，需要进行转换，在这种情况下，flatMap 在指定观察者线程之后，observeOn以确保代码在正确的线程中执行。