Disposable d = timer.get();
if (d != null) {
d.dispose();
}
DebounceEmitter<T> de = new DebounceEmitter<T>(t, idx, this);
<BUG>if (!timer.compareAndSet(d, de)) {
return;
}</BUG>
d = worker.schedule(de, timeout, unit);
<BUG>de.setResource(d);
}</BUG>
@Override

Disposable d = timer.get();
if (d != null) {
d.dispose();
}
DebounceEmitter<T> de = new DebounceEmitter<T>(t, idx, this);
if (timer.compareAndSet(d, de)) {
d = worker.schedule(de, timeout, unit);
de.setResource(d);
}
}
@Override
