либо я вас не понимаю, либо вы делаете что-то не то. Если вам нужны результаты тогда зачем юзать completable? completable - либо завершается без результата, либо с ошибкой. Вы же хотите извлечь результат из completable. Заюзайте тогда maybe, в случае успеха возвращаете что то и обрабатывайте, в случае неуспеха просто Maybe.empty и обрабатывате в соответствующем блоке - не уверен что это то что нужно, я не знаю задачи, но как вариант. Но факт остается фактом если надо значение непонятно зачем юзать completable. Или просто два сингла и зипануть результаты - тут надо исходить из контекста - вариантов хватает

подскажите с rx2
есть список элементов такого вида:
val items: List<B> = listOf()

где B

class B {
   val items: List<B> = listOf()
   var someField = false
}

нужно вывести список B, в котором будет родительский B и дочерние, если items в родительском не пустой, то во всех дочерних somefield = true, если он пустой - то только родительский B в списке
список должен быть упорядоченным

Не совсем ясно, причем тут rxjava?

Что именно смутило?

то что здесь нет зависимости от rxjava. тут обычные java streams

+

на rx нельзя делать то, что можно на стримах джавы?
нет возможности использовать стримы

Всем привет

Есть запрос из разных мест приложения к апи, через одни и тот же метод, можно ли залогировать это так, что бы вместо трех запросов выполнялся только один, а остальные становились на «паузу» и получали результат его выполнения?

Есть вот мысли какие-нибудь как это решить без statemanagement с одни rxjs на проекте?

Мне кажется тут вопрос архитектуры. Может быть вашу задачу можно решить репозиторием, который кэширует результат. И из разных мест приложения дергать этот репозиторий? Если я не прав, пусть меня поправят.

если прям поверхностно - выставьте наружу какой из сабжектов, и отдавайте всем его, а внутри получайте данные  со своего метода и и кидайте в этот сабжект - и будет как хотите - 1 запрос - а остальные будут в ожидании ответа, ну или будут получать его из кеша уже через тот же subject

Смотри в сторону publishReplay

Добрый вечер. Я новичок в rx. Помогите, разобраться. Я понял, как мне работать с одним итемом, а как можно красиво сделать, если мне нужно создать много подписок.
Допустим, раньше мне нужно было по ид юзера подписаться на его обновления. Делал я это примерно так:
observeUser(Id)
Теперь есть список айдишников, нужно подписаться на них, но сам observable не расширять для списка, а использовать именно этот, принимающий одно число. Надеюсь, ясно сформулировал.

Несовсем понятно следующее:
>Теперь есть список айдишников, нужно подписаться на них, но сам observable не расширять для списка, а использовать именно этот, принимающий одно число. Надеюсь, ясно сформулировал.

Что значит observable не расширять для списка?

Всем привет.

Как лучше выполнить два Completable, один за другим. Причём, если первый заэмитет ошибку, то второй всё равно нужно выполнять?

andThen, concat не подходят, т.к. если первый  completable эмитет error, то второй даже не запускается.

Можно обвесится andThen и onErrorReturn, но хочется решения получше

Привет. А какой смысл один за другим выполнять, если фактор появления ошибки не влияет на выполнение следующего?

Ну они связаны между собой. Я был не совсем точен в вопросе. Если ошибки не было или была определённая ошибка, то я хочу выполнить второй.

Пока решает задачу пара andThen и onErrorReturn

Н самое простое рабочее это 2й вынести в метод где он стартует
В первом в он комплит вызвать метод,и в первом же онЕрорРезюмНекст вызвать метод

.take(1) берет первый элемент обсервабла, так? А что будет когда обсервабл получит новое значение?