Модификация Observable при помощи дополнительного запроса в сеть — android kotlin rxjava

1 Звезда2 Звезды3 Звезды4 Звезды5 Звезд
Загрузка...

Вопрос:


работаю с Vk.APi и произвожу поиск списка групп.

В ответе с API получаю список групп, но проблема в том, что каждая из них не содержит количество участников, поэтому мне приходиться для каждой группы производить повторный запрос к API, чтобы получить список участников для каждой группы.

И я столкнулся с проблемой — не знаю, как правильно преобразовать список полученных групп.

Прошу вашей помощи.

Интерфейс для обращения к API:

interface GroupApi {

    @GET(ApiMethods.SEARCH_GROUPS)
    fun getGroups(@QueryMap map: Map<String, String?>) : Observable<GroupResponse<Group>>

    @GET(ApiMethods.SEARCH_MEMBERS_INFO)
    fun getMembersIds(@QueryMap map: Map<String, String?>) : Observable<GroupResponse<String>>
}

Классы получаемой модели:

data class GroupResponse<T>(
        @SerializedName("response")
        @Expose
        val response: Response<T>?
)

data class Response<T>(
        val count: Int,
        val items: List<T>
)

Класс Group довольно большой, главное, что в нем есть поле membersCount, которое необходимо заполнить

Rx code:

private fun test(q: String): Observable<List<Group>> {
         interactor?.let {
             it.getGroupList(q)
                    .flatMap { groupResponse: GroupResponse<Group> -> Observable.just(groupResponse.response?.items) }
                    .flatMap { groupList: List<Group> -> Observable.fromIterable(groupList) }
                    .flatMap { group: Group ->
                        Observable.zip(Observable.just(group), interactor?.let { it.getGroupMembersInfo(group.id.toString()) },
                                BiFunction { group: Group, groupMembersResponse: GroupResponse<String> ->  {
                                    group.membersCount = groupMembersResponse.response?.count.toString()
                                }})
                    }
        }
        //how should I return data ?
    }

К тому же, кажется, мой код почему то очень странно работает. список групп достать получается, а вот уже дополнительный запрос не отрабатывает.

Может быть я еще с flatMap намудрил чего ?

Автор вопроса: Andrew

Источник

Вам также может быть интересно:

Использование вложенных маршрутов в React Router — javascript reactjs react-router
Вопрос: Для организации маршрутов в приложении использую React Router. <Route path="/" component={...}> <IndexRoute component={...}/> <Route path="user/:userId" component={...}> ...
Как с помощью Retrofit 2.0 отправить данные в JSON на сервер и получить ответ? — java android retrofit
Вопрос: Только начал читать про Retrofit 2.0 до этого использовал HttpURLConnection. Как я работаю с HttpURLConnection, формирую Json перевожу его в byte, ставлю header в ...
Не приходят push уведомления. FCM — android firebase android-notification
Вопрос: Появилась необходимость реализовать push уведомления. Прописал в манифесте сервис: <service android:name=".MyFirebaseMessagingService"> <intent-filter> ...
Принцип браузерной игры в линукс терминале — java linux terminal
Вопрос: Наткнулся на Java библиотеку CHARVA. И хотел бы уточнить у знающих людей, возможно ли на основе данной библиотеки сделать программу по принципу браузерной игры, но ...
Мерцание заблокированного экрана при выключенной подсветке в Debian 8 Gnome 3 — linux debian экран
Вопрос: На ноутбуке с Debian 8 Jessie и Gnome 3 имеется следующая проблема. При выключенном заблокированном экране сквозь него можно наблюдать, как весь экран становится белым, ...
Создание WCF клиента на готовый SOAP web сервер — c# wcf
Вопрос: Доброго времени суток. Появилась задача опрашивать web сервер с клиента на котором планируется написать WCF клиентскую часть. Информации про сервер очень мало (не знаю платформу ...
Безопасно ли удалить файл логов general_log.txt? — mysql
Вопрос: При выполнении запроса со вставкой данных большого объёма SQLyog начал вылетать с ошибкой: not enough memory application terminated В связи с этим я решила ...
Callback функции создания таблицы mysql в nodejs — mysql node.js callback
Вопрос: Есть функция, которая при запуске создает базу даных, function showDb() { pool.query("show databases like 'bt' ",function (err, ...
Как создать Adapter с неограниченным количеством строк и с неограниченным разным количеством столбцов в каждой строке — java android
Вопрос: Как создать Adapter с неограниченным количеством строк и с неограниченным разным количеством столбцов в каждой строке Автор вопроса: Salut Amigo Источник
Не могу передать байтовый массив в контроллер — c# asp.net-mvc entity-framework
Вопрос: У меня изображения храняться в бд в формате байтового массива, через форич отлично все выводит, но когда я хочу открыть страницу для работы с ...
proguard release error — java android mvp
Вопрос: Включил в проекте proguard, apk собирается, все хорошо, но приложение не работает) Proguard-rules.pro -keepattributes InnerClasses -keepattributes EnclosingMethod -keepattributes *Annotation* -dontoptimize # Keep Butterknife -keep class butterknife.** { *; } -dontwarn butterknife.internal.** -keep ...
Не отрабатывает page:update — javascript ruby-on-rails
Вопрос: Есть мой учебный проект на ruby. Делаю редактирование объектов с помощью JS. Сейчас работает так: Редактирую первый раз - всё нормально. Не обновляя страницу, ...
Как найти определенный символ в строке и удалить значение после него (и вместе с ним) Jquery — javascript html jquery
Вопрос: Здравствуйте, есть определенный набор строк, типа "L / Красный / 12345", как можно на странице найти их, и вырезать из них все что находится ...
Почему не работает wildcard module declaration? — typescript
Вопрос: Почему не работает такой способ декларации: declare module "*!text" {} ? Цель - использовать контент файла в переменной: import layout = require("/js/views/layouts/wnd.html!text"); или так: import layout from "/js/views/layouts/wnd.html!text"; Если ...
Как прервать 3rd-party код? — c# многопоточность .net-core
Вопрос: Есть 3rd-party код из библиотеки который "зависает" в ожидании где-то в работе с сетью. CancellationToken поддержки нет, таймаутов нет. Запускаю я его через: Task.Run(() => ...

Оставьте ответ

Ваш e-mail не будет опубликован. Обязательные поля помечены *