не стоит

если приложение большое и плотно использует рх, то переход вермя займет

а плюсов от такого перехода не так много

Кстати, недавно на медиуме читал, и там пишут, что создавать новый объект на каждый оператор, это норма, это решает иммутабельность, что есть Гуд в функциональном подходе, на сколько это верно, не разбирал, некогда было :)

Ситуация: идёт поток из моделек (Observable<PhoneContactModel>). В этом потоке идёт около 600 моделек, нужно их же разбить на потоки до 100 моделек и отправить вниз для дальнейшей обработки. Как это сделать?

может изначальный поток разбить на порции?

один из вариантов buffer, видимо.

тоже так подумал, сейчас пробую, спасибо

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

Контакты отправляются пачками по 100, поэтому обновление хэша в репозитории происходит только в случае, если  успешно прошли все запросы на сервер.

Сейчас я сохраняю состояние в функции, что мне не очень нравится, но кажется лучшим решением, чем пробрасывать тот же хеш через десяток операторов.

Кто как решает подобную задачу?

.flatMap(aInteger -> cachedPhoneContacts.toList())
.flatMap(aInteger -> mFriendsRepository.checkFriends(cachedPhoneContacts))

во втором флэтмапе опечатка, да?

вроде не Integer там

а вообще по делу сказать нечего) если кто-нибудь знает как решить проблему, буду рад узнать тоже)

я делал через 2 таблицы в бд, 1 с тем что уже отправляли, вторая с тем что надо отправить, сначала берем все и проверяем контакты которые изменились или добавились, и их добавляем в таблицу которые надо отправить, как проверили все, берем пачками контакты из только что сделаной таблицы и отправляем, если success то трем их в этой бд и идем к сл пачке

Да, просто крутил - вертел типы и вызовы, перестал обновлять названия аргументов)

как насчет
.flatMap(hash ->
      mFriendsRepository
           .checkFriends(cachedPhoneContacts)
         //логика внутри flatMap
           .doOnSuccess(_ -> mFriendsRepository
                                                   .savePhonesHashCode(hash))
)

Неплохая идея, попробую

как корректно отменить запрос, чтобы потом тут же его запустить (но с новыми параметрами)?

switchMap