Wrapping with transformers

gistfile1.java

private CompositeSubscription subscriptions = new CompositeSubscription();

public <T> Observable<T> subscribe(Observable<T> observable) {
    subscriptions.add(observable.subscribe());
    return observable;
}

public <T> Observable.Transformer<T, T> subscribeTransformer() {
    return new Observable.Transformer<T, T>() {
        @Override
        public Observable<T> call(Observable<T> observable) {
            return subscribe(observable);
        }
    };
}