АК
ну тогда не будешь же ты писать туплы на 255
Size: a a a
2020 September 28
АК
такое себе
АК
ради сохранения типизации
НП
Это да. Наверное, из кодстайлов пришло
2020 October 01
AP
Ребят, всем привет. Третий день пытаюсь решить задачу и никак не сдвинусь, буду рад, если кто-то поможет советом.
Есть subject в который шлются эмиты-id. Каждый такой эмит запускает на выполнение Completable. Если пришло несколько эмитов с разным ID, то запускаем параллельно несколько Completable. Если во время выполнения Completable, пришёл новый эмит с ID таким же, как у того, который его запустил, то мы отменяем текущий Completable и запускаем новый.
Все было просто, пока не нужна была отмена с условием
Есть subject в который шлются эмиты-id. Каждый такой эмит запускает на выполнение Completable. Если пришло несколько эмитов с разным ID, то запускаем параллельно несколько Completable. Если во время выполнения Completable, пришёл новый эмит с ID таким же, как у того, который его запустил, то мы отменяем текущий Completable и запускаем новый.
Все было просто, пока не нужна была отмена с условием
AP
Даже как подступиться не знаю. По сути switchMap(flatMapLatest) и flatMap с зависимостью от эмита.
АК
ну я бы делал так что на каждый айдишник у тебя создается сабджект если такового не существует. если существует - в него пихаешь, а сабджект на свичмапе
АК
по другому пока хз ибо выглядит так что тебе нужно хранить каждый стрим
AP
ну я бы делал так что на каждый айдишник у тебя создается сабджект если такового не существует. если существует - в него пихаешь, а сабджект на свичмапе
Мысль понял, пойду играть от неё. Я так не думал ещё. Спасибо
АК
Мысль понял, пойду играть от неё. Я так не думал ещё. Спасибо
АК
ну и говно конечно(
AP
да уж, выглядит стремновато, но может быть это единственное решение
l
Ребят, всем привет. Третий день пытаюсь решить задачу и никак не сдвинусь, буду рад, если кто-то поможет советом.
Есть subject в который шлются эмиты-id. Каждый такой эмит запускает на выполнение Completable. Если пришло несколько эмитов с разным ID, то запускаем параллельно несколько Completable. Если во время выполнения Completable, пришёл новый эмит с ID таким же, как у того, который его запустил, то мы отменяем текущий Completable и запускаем новый.
Все было просто, пока не нужна была отмена с условием
Есть subject в который шлются эмиты-id. Каждый такой эмит запускает на выполнение Completable. Если пришло несколько эмитов с разным ID, то запускаем параллельно несколько Completable. Если во время выполнения Completable, пришёл новый эмит с ID таким же, как у того, который его запустил, то мы отменяем текущий Completable и запускаем новый.
Все было просто, пока не нужна была отмена с условием
groupingby(v -> v.id).flatmap(obs -> obs.switchmap(v -> toCompletable(v)), 5)AP
groupingby(v -> v.id).flatmap(obs -> obs.switchmap(v -> toCompletable(v)), 5)это сработает, если observable на котором вызывается groupBy будет бесконечным?
АК
groupingby(v -> v.id).flatmap(obs -> obs.switchmap(v -> toCompletable(v)), 5)сильно
АК
должно сработать
AP
потому что я этот вариант рассматривал, и у меня не получилось
AP
попробую снова, спасибо
l
это сработает, если observable на котором вызывается groupBy будет бесконечным?
вопрос про ид открыт. насколько из много уникальных и сколько они весят