Разбираюсь с использованием RxJava в Android, возник вопрос следующего рода. Я сделал вот такую extension функцию:
fun <T: View> T.setReactiveOnClickListener(): Flowable<View> {
val subject = PublishSubject.create<View>()
this.setOnClickListener {
subject.onNext(it)
}
return subject.toFlowable(BackpressureStrategy.DROP)
}
Которую можно использовать следующим образом:
btnBack
.setReactiveOnClickListener()
.map { finish() }
.subscribeOn(AndroidSchedulers.mainThread())
.subscribe()
Проблема заключается в том, что при закрытии активности, стрим должен как-то об этом узнать и отмениться. Иначе это приведет к прямой утчке памяти. Я посмотрел возможные коллбеки View, ничего не нашел вроде onDestroy, где можно было бы отловить окончание жизни вьюхи. Конечно можно решить проблему в лоб и сделать централизованный стор стримов активности и явно дергать его очитску при закрытии активности, но как-то это не очень элегантное выглядит. Что можете предложить?