时间戳

首页 > 解决方案 > 将 Observable 结果传递给另一个无穷无尽的 Observable

android - 将 Observable 结果传递给另一个无穷无尽的 Observable

问题描述

我对 RxJava 完全陌生，我想实现一些应该很容易的事情，但我似乎还不能完全理解。

我有一个 Retrofit 调用，它返回一个带有我的 POJO 列表的 Observable。然后如果有更多的电话要打，它会要求另一个列表，一段时间后我可能想再问一个列表。

result.subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe({ pojoArray: ArrayList<POJO> ->
                //TODO: pass the results on to other observable
                if (pojoArray.size == pageSize) {
                   //array is full, there is more pages to call
                   //call Retrofit again for more POJO
                }
            }

每次我想调用 Retrofit 调用时，它都会返回一个新的 Observable，我订阅它以获取 ArrayList

然后我想做的是拥有另一个 Observable，外部客户端可以观察和接收 POJO 的透明流。因此，每次改造返回给我 ArrayList 时，我都想将列表中的所有对象推送到这个 Observable 中，并使用无穷无尽的 POJO 流。

每次收到来自 Retrofit 的响应时，如何创建可以将 POJO 对象推送到的无限 Observable？

标签： androidretrofit2rx-java2pojo

解决方案

推荐阅读