source.subscribe(observer);
} else {
Scheduler.Worker w = scheduler.createWorker();
source.subscribe(new ObserveOnObserver<T>(observer, w, delayError, bufferSize));
}
<BUG>}
static class Padding0 extends AtomicInteger {
private static final long serialVersionUID = 3172843496016154809L;
volatile long p01, p02, p03, p04, p05, p06, p07;
volatile long p08, p09, p0A, p0B, p0C, p0D, p0E, p0F;
}
static final class ObserveOnObserver<T> extends Padding0 implements Observer<T>, Disposable, Runnable {</BUG>
private static final long serialVersionUID = 6576896619930983584L;

source.subscribe(observer);
} else {
Scheduler.Worker w = scheduler.createWorker();
source.subscribe(new ObserveOnObserver<T>(observer, w, delayError, bufferSize));
}
}
static final class ObserveOnObserver<T> extends BasicIntQueueDisposable<T>
implements Observer<T>, Runnable {
private static final long serialVersionUID = 6576896619930983584L;
