rxjava +改造-如何等待并获得android中第一个可观察的结果？

Question

我最近开始学习retrofit 和rxjava。我正在寻找有关如何等待获得第一个可观察结果的任何想法。基本上，我想将它应用于简单的登录。第一个 api 调用正在获取服务器时间。第二个 api 调用将等待第一个调用的结果（即服务器时间）并利用它。

                Retrofit retrofit = RetrofitClient.getRetrofitClient();
                LocalServerInterface apiInterface = retrofit.create(LocalServerInterface .class);

                Observable<ServerTime> timeObservable = retrofit
                        .create(LocalServerInterface .class)
                        .getTime()
                        .subscribeOn(Schedulers.newThread())
                        .observeOn(AndroidSchedulers.mainThread());

                Observable<ServerNetwork> serverNetworkObservable = retrofit
                        .create(LocalServerInterface .class)
                        .getNetworks(//valuefromapicall1, anothervalue)
                        .subscribeOn(Schedulers.newThread())
                        .observeOn(AndroidSchedulers.mainThread());

现在，我被困在这里了。在第二个 observable 上，特别是在 getNetworks 方法上，我想使用从第一个 observable 中得到的东西。有什么想法吗？

编辑：

我想先处理调用 1 的结果，然后再将其提供给 api 调用 2。可以吗？

Answer 1

首先，不要每次都重新创建LocalServerInterface，创建一个并重用它。创建接口实例是一项昂贵的操作。

LocalServerInterface apiInterface = retrofit.create(LocalServerInterface.class)

并且要使第二个 observable 以第一个 observable 的结果开始，您需要执行flatMap。

Observable<ServerNetwork> serverNetworkObservable = apiInterface
                        .getTime()
                        .flatMap(time -> apiInterface.getNetworks(time, anothervalue))
                        .subscribeOn(Schedulers.newThread())
                        .observeOn(AndroidSchedulers.mainThread());

请参阅flatMap documentation 了解更多信息。

重要提示。在这种情况下，当第一个 observable 只发出一个响应时，使用flatMap 和concatMap 没有区别。对于其他情况，请考虑the difference between flatMap and concatMap。