Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
Wrapping with transformers
private CompositeSubscription subscriptions = new CompositeSubscription();
public <T> Observable<T> subscribe(Observable<T> observable) {
return observable;
public <T> Observable.Transformer<T, T> subscribeTransformer() {
return new Observable.Transformer<T, T>() {
public Observable<T> call(Observable<T> observable) {
return subscribe(observable);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment