public <T> void add(Observable<T> observable, Action1<? super T> action) {
if (Looper.myLooper() != Looper.getMainLooper()) {
throw new AssertionError("Must be on main thread");
}
subscriptions.add(observable.subscribeOn(subscribeOnScheduler)
.observeOn(observeOnScheduler)
.subscribe(action));
}