等待定位，然后使用 rxjava 执行改造调用

Question

在我的应用程序中，我需要等待用户位置，然后执行改造（收到位置时）。

我有可观察的工作

mlocationService.getLocation()
            .timeout(LOCATION_TIMEOUT_SECONDS, TimeUnit.SECONDS)
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(location -> {
                Log.d(TAG, "COORDS: " + location.getLatitude() + ", " + location.getLongitude());
            }, e -> Log.e(TAG, e.getMessage()));

但是现在我需要通过改造调用来调用第二个 observable，有没有比将第二个 observable 嵌套在第一个的 onNext() 中更好的方法？

谢谢

Answer 1

是的，您可以使用flatmap 运算符：

mlocationService.getLocation()
        .timeout(LOCATION_TIMEOUT_SECONDS, TimeUnit.SECONDS)
        .subscribeOn(Schedulers.newThread())
        .flatmap(location -> retrofitApi.getData(location))
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(...)

订阅现在将获得改造调用的结果

如果您需要同时返回改造结果和位置，则可以使用 zip 运算符：

mlocationService.getLocation()
        .timeout(LOCATION_TIMEOUT_SECONDS, TimeUnit.SECONDS)
        .subscribeOn(Schedulers.newThread())
        .flatmap(location -> Observable.zip(
            retrofitApi.getData(location),
            Observable.just(location),
            (Func2<Response<Data>, Location, ResponseLocation>) (response, location) -> {
                return new ResponseLocation(response, location)
            }
        ))
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(...)

其中 ResponseLocation 只是一个获取位置和改造结果的类。然后订阅将获得一个 ResponseLocation 作为它的参数。

编辑

要在调用 Retrofit 之前使用该位置，只需扩展 lambda：

mlocationService.getLocation()
        .timeout(LOCATION_TIMEOUT_SECONDS, TimeUnit.SECONDS)
        .subscribeOn(Schedulers.newThread())
        .flatmap(location -> {
            updateMap(location);
            return retrofitApi.getData(location);
        })
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(...)