Сделал по другому, вроде разобрался и сам. Спасибо что дали на это время

Короче. Буду учить как собрать приложуху на андроид. Нафиг эти питоны и кресты.

Привет всем!
Помогите решить такой кейс:

Есть запрос на получение папок (директорий):
getDirectories(id: Int): Flowable<List<Directory>>

И запрос на получение оборудования, которое лежит в этих папках:  
getEquipments(id: Int): Flowable<List<Equipment>>

Я получаю через zipWith оба списка, и объединяю их:

getDirectories(id)
  .zipWith(getEquipments(id),

        BiFunction


<List<Directory>, List<Equipment>, List<DirectoryAndEquipment>>
         { directories, equipments ->
         //Вызов метода для объеденения
         return someList
         }

)

Нужно, чтобы при onNext любого из Flowable вызывалась BiFunction. Проблема в том, что тело BiFunction вызывается только тогда, когда изменяются и директории и оборудования (т.е в getEquipments отработал onNext, а в getDirectories ничего не изменилось и BiFunction не вызвалось)

Решение: combineLatest

Народ, привет

Работал кто c Firebase используя Rx

?

Задавай сразу вопрос

Есть БД в ней 10 объектов, я оборачиваю listener (который оповещает об изменениях) в кастомный single observable.
При первом обращении к бд listener как бы не знает что в бд что-то есть и он думает что у меня были изменения, следовательно мне в презентер прилетает 10 объектов Single.
Это как я понял особенность самого Firebase, потому что первое обращение к ней заведомо позиционируется как изменение бд, для получения информации из нее

можно ли как-то вернуть списком

?

Может кто-то сталкивался

Он не думает, что у тебя были изменения
Сингл возвращает тебе все элементы при подписке на него и сразу же отписывается
А сам вопрос не понятен. Что вернуть списком?

он эмитит 10 объектов,по очереди и я вызываю 10 раз метод метод (в котором я обновляю Recycler).
Допустим оператор Debounce? А про список, я имел ввиду собрать обекты в коллектцию и передать его в метод обновления View 1 раз

Как сингл может эмиттить 10 объектов по очереди? У него нет onNext

Покажи код

метод в строке 19

Попробуй в onChildAdded собирать все dataSnapshot в список, а перед Single.create, эмитнуть его