ViewBinding

syntetic депрекейтнутий, ну и ничего тебе не мешает использовай тот же файнВюБайИд

Привет. Помогите въехать в тему, плиз.
У меня есть шедулер, который проверяет, есть ли подписки (экземпляры UI).  
Если подписки есть - то дергает данные из базы и раздает полученные результаты каждому подписавшемуся.
Каждый подписавшийся смотрит результатах - есть ли данные конкретно для него и работает с ними, если есть.
Если UI отключилась - то нужно отписать эту UI от получения данных.
Как это переделать с использованием RxJava?

Я мыслю не в терминах RxJava, судя по всему. А очень хочется научиться...

я не большой эксперт в rxJava, я бы сделал так. Использовал CompositeDisposable - и когда ui - это видимо активити или фрагмент? - onDestroy - compositeDisposable.dispose - то есть отписывается во время уничтожения вьюхи

Спасибо за ответ. Изучаю )

Как можно заставить Observable перезапустить всю цепочку? Например нужно мне по шедулеру дернуть данные из базы и раздать эти данные обсерверам...

то есть заставить observable заново выполнить запрос в базу?

да

если observable не шарить через .share - при подписке оно и так заново будет отрабатывать. Ну насколько мне известно

спасибо, читаю )

Подскажите пожалуйста, прохожу третий урок по Rx и застопорился в теме:Создание своего Observable , а именно Observable.OnSubscribe<Integer> onSubscribe = new Observable.OnSubscribe<Integer>()
во второй Rx, как то по другому метод OnSubsctibe называется?

Привет. Ребят, какие операторы взять? Есть 2 дата сорса. Оба тянут одну модель. Сначало первый дата сорс возвращает данные. Если onFailure, то делаю запрос из второго, и если уже и там ошибка, то вызываю показ ошибки. Как правильно с помощью операторов такое реализовать?

2 вызова не параллельных, тогда subscribe(onError={callAgain()})
Я бы так сделал

Сделать рекурсию?

А, кстати, если будет лист дата сорсов, то без рекурсии не обойтись, спасибо!

это не рекурсия, это асинхронная работа же

Ну если у меня лист дата сорсов, ырыкс не поддерживает такую работу

Приходится делать метод получения и в onFailure себя же вызывать

onErrorResumeNext в репозитории