RXUtils.java

import rx.Observable;
import rx.Subscription;
import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Action1;
import rx.schedulers.Schedulers;

/**
 * Created by levenetc on 23/06/15.
 */
public class RXUtils {

	static Observable.Transformer schedulersTransformer = new Observable.Transformer<Object, Object>() {
		@Override public Observable<Object> call(Observable<Object> observable) {
			return observable
					.subscribeOn(Schedulers.io())
					.observeOn(AndroidSchedulers.mainThread());
		}
	};

	public static void disableScgedulersTransformer() {
		schedulersTransformer = new Observable.Transformer<Object, Object>() {
			@Override public Observable<Object> call(Observable<Object> observable) {
				return observable;
			}
		};
	}

	@SuppressWarnings("unchecked")
	public static <T> Observable.Transformer<T, T> applySchedulers() {
		return (Observable.Transformer<T, T>) schedulersTransformer;
	}

	public static void unsubscribe(Subscription... subscriptions) {
		if (subscriptions != null)
			for (Subscription sub : subscriptions)
				if (sub != null) sub.unsubscribe();
	}
}