3

Я получаю с сервера список чатов(переписок). Их запихиваю в класс 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, дальше ничего не происходит, то есть до подписчика не доходит ничего, точнее подписчик никак не реагирует.

Вопрос: Как исправить это и вообще как правильно решать такого рода задачи?

8
  • 1
    небольшое замечание. Ваш код довольно сложно читать в силу очень большой вложенности. Попробуйте его декомпозировать. По опыту, после грамотной декомпозиции неявные ошибки начинают сами бросаться в глаза
    – rjhdby
    10 ноя 2017 в 22:05
  • Спасибо за замечание. Совсем забыл об этом...
    – DevOma
    10 ноя 2017 в 22:08
  • Смотрите, у вас chatsModel наполняется внутри getUsersByChats subscribe, что, по сути равносильно наполнению в коллбеке. А return chatsModel сразу за этой подпиской. Т.е. на момент return вызов getUsersByChats еще не завершен
    – rjhdby
    10 ноя 2017 в 22:11
  • Ой извиняюсь. Я не заметил ваш комментарий и внес изменения.
    – DevOma
    10 ноя 2017 в 22:18
  • Ну суть проблемы не изменилась. Вы делаете return chatsModel до того, как отработал subscribe. Вы, по сути, этим return'ом убили всю идею ReactiveX. Вам надо из loadUsersById возвращать не готовый объект, а Observable на него и выше по коду подписываться на него
    – rjhdby
    10 ноя 2017 в 22:24

1 ответ 1

1

Если формально, то проблема ваша в том, что вы делаете return chatsModel до того момента, как выполнится код из subscribe, в котором он наполняется.

Если по сути, то ошибка у вас в идеологии. Вы пытаетесь скрестить ежа с ужом. Идеология ReactiveX состоит в том, что вы управляете не фиксированными объектами, а потоками данных(событий), причем асинхронно. А у вас получается так: пошел асинхронный поток, вы его тут-же пытаетесь собрать в объект, синхронно причем, и запустить в другой поток.

Распишем ваш поток:

  1. Происходит какое-то событие, которое инициирует загрузку чатов
  2. Получаем список чатов List<Chat>
  3. Для каждого чата получаем информацию о пользователе (getUserInfo)
  4. Делаем с этими чатами какую-то полезную работу (redrawMyNiceChatsTable)

Т.е. логика у вас должны быть примерно следующая(отчасти псевдокод):

class MyMainClass{
    private ChatsUpdater updater = new ChatsUpdater();
    private List<Chat> chats = new ArrayList<>();

    private void onSomeEventOccured(){
        chats.clear();
        updater.startUpdate()
            .subscribe(
                {chat -> chats.add(chat)},     // onNext
                {redrawMyNiceChatsTable(chats)} // onComplete
            )
    }
}

class ChatsUpdater{
    public Flowable<Chat> startUpdate(){
        return getChats().flatMap(
                    chat -> getUserInfo(chat), 
                    (chat, userInfo) -> {
                        chat.setUserInfo(userInfo);
                        return Observable.just(chat);
                    }
                )
    }

    private Flowable<Chat> getChats(){
        .....
    }

    private Flowable<UserInfo> getUserInfo(Chat chat){
        .....
    }
}

UPD Ну а если совсем по уму, то, так как у вас жесткая, обязательная, цепочка Chat->UserInfo, вам надо переделать API на стороне сервера, чтобы оно отдавало сразу всю необходимую информацию.

2
  • Сейчас я переделываю все, как вы сказали. Декомпозиция. Суть реактивного подхода походу я понял. А насчет API, то это API VK)
    – DevOma
    12 ноя 2017 в 4:34
  • Все спасибо. Сработало. Я не знал об одном, что можно в flatMap использовать два Function
    – DevOma
    13 ноя 2017 в 3:49

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.