Как отписаться в RxJava внутри Consumer?

Question

[Drottarutarnum]

У меня есть класс который передает посылки со статусом всем своим подписчикам 20 раз в секунду

И если девайс переходит из состояния Run в состояние End - надо переключить активити
Проблема в том, что подписка остается даже если я убиваю предыдущее активити и т.к. условие соблюдено, Consumer выполняет переход на другое активити по 20 раз в секунду, постоянно

По этому мне надо как-то отписываться, как это можно сделать внутри самого Consumer?

Comments

[Денис Загаевский]

ничего не понял

[Drottarutarnum]

Денис Загаевский, надо убить подписку внутри метода который обрабатывает сообщения