Передать наблюдаемый результат другому бесконечному наблюдаемому - PullRequest
Новая
       7

Передать наблюдаемый результат другому бесконечному наблюдаемому

0 голосов
/ 29 апреля 2018

Я совершенно новичок в RxJava и хочу достичь чего-то, что должно быть достаточно легким, но я пока не могу обернуться.

У меня есть вызов Retrofit, который возвращает Observable со списком моих POJO. И затем, если есть еще звонки, он запрашивает другой список, и через некоторое время я могу попросить другой список. 

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

То, что я хочу сделать тогда, - это иметь другую Наблюдаемую, чтобы внешние клиенты могли наблюдать и получать прозрачный поток POJO. Поэтому каждый раз, когда Retrofit возвращает мне ArrayList, я хочу поместить все объекты из списка в этот Observable с бесконечным потоком POJO.

Как мне создать бесконечную Наблюдаемую, в которую я могу помещать объекты POJO каждый раз, когда получаю ответ от Retrofit?

...