public static Disposable subscribe(@Subject int subject, @NonNull Object lifecycle, @NonNull Consumer<Object> action) {
        Disposable disposable = getSubject(subject).subscribe(action);
        getCompositeDisposable(lifecycle).add(disposable);
        return disposable;
    }


//In your code
Disposable disposable = RxBus.subscribe(RxBus.SUBJECT_MY_EVENT, this, action);


//Somewhere else in your code - calling dispose is equivalent to unsubscribing
disposable.dispose();