или не тот...

не, вроде тот.
Ну я кстати не смотрел за ними годик. Вижу что апнулись.
Надо глянуть остались ли у них траблы с транзакциями. Если нет, то можно под мою ORM вставить и получить пушку гонку вообще

Из-за чего может в цепочке concatMap-ов всё перепрыгивать на zipWith, проигнорировав все последующие concatMap и zipWith?? Ломаю голову и не могу понять, ща крыша поедет.

вчера же это обсуждали. ЗИП не ждёт обс выше

Я простестил отдельно - оказывается, ждёт. Вот тут дуОнНекст вызываются тольо тогда, когда до них доходит. И, что самое интересное, все остальные зипы тоже ждут.

Народ, не могу понять, если я загружаю json довольно крупный, 8 мб, то это будет один вызов onNext? Или для каждого dto, который  в нем?

автоматически сгруппирует по пять элементов

Почему по 5?

Всем привет
Может сможете мне объяснить, кто нибудь
В андроид нужно вытянуть данные из sharedPreferences
Будет длинная история

Тимлид сказал, что инициализировать подписку нужно во вью модели и ответ сетить в BehaviorSubject, а уже на него подписываться из уи
Так я и делал, но данные подгружались с заметной задержкой (замерил через Date().time - около 120-180 мс

Попробовал сделать загрузку данных напрямую (без BehaviorSubject, а сразу слушать Maybe из репозитория)
Данные также подгружаются с задержкой

Далее, я решил замерить время не в subscribe({}), а в doOnNext (для BehaviorSubject) и в doOnSuccess (для Maybe)
Тут уже другая история - если doOnNext показывает те же 120-180 мс, то doOnSuccess выдаёт 7-10мс
И если метод распределения ответа по вью поставить в doOnSuccess, никакой задержки нет

Может ли мне кто-нибудь объяснить, почему такая разница во времени?

@snoozerio упс, сори, случайно ответил на ваше сообщение

Вот для наглядности (внизу кусок лога с временем в мс)

просто удобное число

ну не издевайся ты уже))

да ну прям совсем лютый вопрос, сложно было иначе

выглядит как-то дико. а если убрать все эти сабскрайоны и обзервоны? Пробовали?

Хз, может дело в Schedulers.io()  ?

А как без них подписаться-то?..

А что с ним может быть не так?

Ну, он предназначен для блокирующих операций. Может, задержка какая отсюда.