1

Разбираюсь с использованием 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, где можно было бы отловить окончание жизни вьюхи. Конечно можно решить проблему в лоб и сделать централизованный стор стримов активности и явно дергать его очитску при закрытии активности, но как-то это не очень элегантное выглядит. Что можете предложить?

1

1 ответ 1

0

То что вы пытаетесь написать - уже написано. Посмотрите как ваша задача реализована в RxBinding. Если кратко - вам надо добавить убирание слушателя с View при прекращении действия подписки:

.doOnCancel { this.setOnClickListener(null) }

Метод doOnCancel должен быть вызван, когда актвити завершится. Это надо сделать вручную, например добавляя все подписки в CompositeDisposable, которому в onDestroy активити надо вызвать dispose().


Либо, как указали в комментах - используйте RxLifecycle

2

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.