RxGroups helper

BaseActivityRx.java

protected <T> void autoResubscribe(Observable<T> observable, ResubscriptionObserver<T> resubscriptionObserver) {
        if (getObservableGroup() != null && observable != null) {
            observable
                    .compose(getObservableGroup().<T>transform((String) resubscriptionObserver.resubscriptionTag()))
                    .compose(applySchedulers())
                    .subscribe(resubscriptionObserver);
        }
    }