Подклассы Observable

Question

Я хочу, чтобы подкласс наблюдался для создания наблюдаемого с дополнительной функцией. Дополнительная функция сообщит, что вызывающий объект наблюдаемого имеет активный кеш и немедленно вернется.

Это использование так, что я хочу добиться:

func fetchData(): 
    Observable observable = getObservable() 
    if !observable.hasActiveCache(): 
     showLoading() 

    observable.subscribe(subscriber) 

Так что я только хочу, чтобы показать диалог загрузки, если наблюдаемая будет получать данные из сети.

Я пробовал подклассифицировать наблюдаемый (класс MyObservable extends Observable), и он работает в некоторых случаях. Однако, если где-то в цепочке кто-то делает, например, карту в наблюдаемой, она снова становится регулярной.

Кто-нибудь знает, как я могу это решить?

Answer 1

Типы быстро теряются в RxJava при быстром вызове оператора. Ваш лучший вариант - сохранить ссылку на оригинальную Observable с вашими пользовательскими функциями и вызвать ее напрямую. (У нас есть аналогичные неудобства для наших GroupedObservables, Subjects и ConnectableObservables.)