l
в общем-то, да. а как это реализовать?
take(1) , а дальше?
take(1) , а дальше?
concat(dbObs.take(1), dbObs skip(1).delay)
Size: a a a
2020 June 12
I
concat(dbObs.take(1), dbObs skip(1).delay)
ааа.. понял. Спасибо, через concat
i
Вообще странно ставить дебаунс на дб ) Есть подозрение, что у тебя много изменений происходит в короткий промежуток времени
l
Вообще странно ставить дебаунс на дб ) Есть подозрение, что у тебя много изменений происходит в короткий промежуток времени
ну наверно так и есть) но раз ему бд возвращает реактивный тип, то почему бы не собирать какие-то значения.. последние за 5 сек например
I
Вообще странно ставить дебаунс на дб ) Есть подозрение, что у тебя много изменений происходит в короткий промежуток времени
периодически. и в эти моменты хочу избавиться от флика ui
l
реал-тайм данные
i
Мне кажется в этом случае в первую очередь надо поменеджить обращения к бд
i
если это возможно
i
А потом уже менеджить эмиты из неё
I
Мне кажется в этом случае в первую очередь надо поменеджить обращения к бд
не очень понял, что значит "поменеджить обращения к ДБ"? типо сделать, чтобы их было не так много??
i
не очень понял, что значит "поменеджить обращения к ДБ"? типо сделать, чтобы их было не так много??
Чтобы изменений данных в бд не было много в короткий промежуток времени
i
Например рум эмитит на insert, delete, и если получая данные из сети делать это не одной транзакцией, то можно получить два эмита в дополнение к тому, который происходит при подписке
I
Например рум эмитит на insert, delete, и если получая данные из сети делать это не одной транзакцией, то можно получить два эмита в дополнение к тому, который происходит при подписке
понял, вроде подобного у себя не вижу
EG
В ините вьюмодели вызывают методы. Если потом я еще несколько раз вызывю метод getChannelPlaylistsSubscribe() это норм? Или так низя делать.
АК
оффтоп:
это в 3 Rx появилось addTo у Disposable?
это в 3 Rx появилось addTo у Disposable?
I
У меня есть список
Все они – это запросы к серверу.
Хочу запустить всех параллельно (сделать несколько запросов к серверу одновременно, не по очереди).
Вижу в доках, что
Однако, на деле, вижу, что запросы запускаются не параллельно, а один за другим.
Как же сделать так, что каждый completable выполнялся сразу, а не друг за другом?
Completable. Все они – это запросы к серверу.
Хочу запустить всех параллельно (сделать несколько запросов к серверу одновременно, не по очереди).
Вижу в доках, что
Completable.merge решает мой кейс.Однако, на деле, вижу, что запросы запускаются не параллельно, а один за другим.
Как же сделать так, что каждый completable выполнялся сразу, а не друг за другом?
АК
не проблемы Rx
АК
Rx делает парралельно. Смотри где накосячил
АК
или ссотри что с потоками