т.е. по сути оно становится Single ?

Останется flowable, просто эмит будет один

Привет
Стоит задача добавлять элементы в список, с этого списка создать Observable, если элементы не добавлялись в список последние 300 мс, то отправить запрос на сервер, не подскажите как можно решить задачу?

Debounce

http://reactivex.io/documentation/operators/debounce.html

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

все привет. Подскажите как реализовать. Мне нужно подписаться на несколько observable получить самые первые данные и закомлититься. (Мне нужно проверить содержимое в хранилище по разным ключам, если хоть что-то есть вернуть ture иначе false)

zip + first от каждого observable, либо используй просто синглы как источники данных.

и в конце можешь возвращаться single с нужным значением. Если данные могут вообще не прийти, то лучше использовать Maybe

там будет пустой Set. Вот в сингл и хотел упаковать

Спасибо!

Всем привет!
Никак не могу понять, как работает оператор compose и в чём его отличие от flatmap. Я гуглил, как не в себя, может есть ссылки на какие-то проекты, где он используется? Никто не наталкивался?

The difference is that compose() is a higher level abstraction: it operates on the entire stream, not individually emitted items.
ну типа он на более высоком уровне абстракции и работает со строимом, а flatmap() с выпускаемыми элементами отдельно

т.е. в любом месте цепочки в compose() пойдёт стрим независимо от того, что испустили выше?

рабочий пример где-то бы найти...

ну я просто сам заинтересовался и побыстрому нагуглил на stackoverflow

Есть ли в rxJava какой-нибудь оператор, чтобы toList() собирался в том же порядке, в каком он разобрался в flatMap? Упрощённо код такой:

interactor.getItems()
.flatMapIterable(items -> items)
.flatMap(item -> interactor.getDetails(item.getId())...)
.toList()
.subscribe (...);

Лист полученный от первого запроса к апи преобразуется в отдельные потоки, выполняются отдельные запросы к апи для каждого, и потом все потоки собираются обратно в лист. Проблема в том, что ответы от сервера приходят в разном порядке и в таком же порядке собираются лист. А нужно сохранить первоначальный порядок

нет, flatMap не гарантирует порядок

Можно конечно добавить индексы в в каждый item и вместо toList вызвать toSortedList, но как-то это некрасиво получается

был какой-то другой оператор, не flatmap, который сохраняет порядок

Спасибо, погуглю

concatMap советуют