Нeльзя, во-пeрвых, там сигнатура Func1<Ovservable, Observable>, поэтому как минимум repeatWhen(error -> repearSubject.asObservable()).
Во-вторых, спецификация обязывать возвращать подстрим данного notificationHandler'а. Пeрeданный туда сторонний статичный стрим работать нe будeт.
Имеете ввиду Rx2? Как раз наоборот, работают на Rx1, для миграции на Rx2 нужно не эмитить нуллы, а создавать класс RetryEvent, о чем я написал в середине статьи. Подозреваю, что-то еще придется менять, так как примеры чисто на первой версии писал.
Сложно посоветовать какую-то литературу, потому-что большинство материалов, вроде «RxJava for Android App Development» — K. Matt Dupree, покрывает только самый базовый уровень (хотя именно эту 30 страничную брошюру стоит пробежать, там популярная реактивная обёртка на SearchView продемонстрирована).
Самым эффективным способом будет идти по официальной документации, брать каждый оператор и гуглить отдельно по нему небольшие статьи: «rx debounce usage android», «rx compose transformers usage android».
Очень много годноты находится на хабре и медиуме.
Позже, когда документация, диаграммы из неё и десятки прочитанных примеров врежутся в память, мозг сам начнет выдавать тонны (часто нерабочих) способов переделать собственный код и реализовать какую-то привычную штуку через Rx )
Information
Rating
Does not participate
Location
Санкт-Петербург, Санкт-Петербург и область, Россия
Во-вторых, спецификация обязывать возвращать подстрим данного notificationHandler'а. Пeрeданный туда сторонний статичный стрим работать нe будeт.
Самым эффективным способом будет идти по официальной документации, брать каждый оператор и гуглить отдельно по нему небольшие статьи: «rx debounce usage android», «rx compose transformers usage android».
Очень много годноты находится на хабре и медиуме.
Позже, когда документация, диаграммы из неё и десятки прочитанных примеров врежутся в память, мозг сам начнет выдавать тонны (часто нерабочих) способов переделать собственный код и реализовать какую-то привычную штуку через Rx )