Я получаю с сервера список чатов(переписок). Их запихиваю в класс ChatsModel
. И в этом классе имеется userId
, то есть в каждом чате имеется id
того пользователя. Других информации о пользователе нет.И еще есть одно поле для данных о пользователе типа UserMessagesResponse
.
Так вот для начала этот userMessagesResponse
равен null
.
После того как я получил список чатов и userId
, я должен отправить другой запрос для получения информации о пользователе. Делаю я это таким образом:
private void loadChatsFromNetwork(int count, AccessDataModel accessDataModel) {
String accessToken = accessDataModel.getAccessToken();
Flowable<ChatsModel> chatsModelSingle = getChatsApi().getChats(count, accessToken, Constants.api_version)
.subscribeOn(Schedulers.io())
.flatMap(chatsModel -> {
RealmList<Item> items = chatsModel.getResponse().getItems();
StringBuilder userIds = new StringBuilder();
for (Item item : items) {
userIds.append(item.getMessage().getUserId()).append(",");
}
return loadUsersById(userIds, chatsModel);
})
.observeOn(AndroidSchedulers.mainThread());
chatsModelSingle.subscribe(chatsModel -> {
Log.d(TAG, chatsModel.getResponse().getItems().first().getMessage().getMessagesUserItem().getFirstName());
chatsRepository.updateChatsData(chatsModel);
iGetChatsCallback.onGetChatsSuccess(chatsModel);
},
throwable -> {
iGetChatsCallback.onGetChatsError(throwable.getMessage());
Log.d(TAG, "onError() " + throwable.getMessage());
});
}
private ChatsModel loadUsersById(StringBuilder userIds, ChatsModel chatsModel) {
MyApplication.getChatsApi().getUsersByChats(userIds.toString(), "photo_100")
.subscribe(messagesUser -> {
RealmList<Item> item = chatsModel.getResponse().getItems();
for (int i = 0; i < item.size(); i++) {
Message message = item.get(i).getMessage();
RealmList<UserMessagesResponse> messagesUserItemList = messagesUser.getUserMessagesResponse();
for (UserMessagesResponse messagesResponse : messagesUserItemList) {
if (messagesResponse.getUid().equals(message.getUserId())) {
message.setMessagesUserItem(messagesResponse);
chatsModel.getResponse().getItems().get(i).setMessage(message);
}
}
}
});
return chatsModel;
}
Все эти действия происходят в операторе flapMap
, так как мне нужно полученную информацию о пользователе запихнуть в поле userMessagesResponse
класса ChatsModel
. И в случае успеха отправляю в adapter.
Оба запроса корректно работают. Получаю список userid
, получаю данные о пользователе.
Проблема в том, после возвращения chatsModel
в flatMap
, где return chatsModel
, дальше ничего не происходит, то есть до подписчика не доходит ничего, точнее подписчик никак не реагирует.
Вопрос: Как исправить это и вообще как правильно решать такого рода задачи?
getUsersByChats
subscribe
, что, по сути равносильно наполнению в коллбеке. Аreturn chatsModel
сразу за этой подпиской. Т.е. на моментreturn
вызовgetUsersByChats
еще не завершенreturn chatsModel
до того, как отработалsubscribe
. Вы, по сути, этим return'ом убили всю идею ReactiveX. Вам надо изloadUsersById
возвращать не готовый объект, аObservable
на него и выше по коду подписываться на него