How to unsubscribe in RxJava inside a Consumer?

Question

Java

I have a class that sends status messages to all its subscribers 20 times per second
. And if the device goes from the Run state to the End state, you need to switch the activity
. the condition is met, the Consumer performs a transition to another activity 20 times per second, constantly.
Therefore, I need to somehow unsubscribe, how can this be done inside the Consumer itself?