this.idx = idx;
this.parent = parent;
}
@Override
public void run() {
<BUG>emit();
}
void emit() {</BUG>
if (once.compareAndSet(false, true)) {
parent.emit(idx, value, this);

this.idx = idx;
this.parent = parent;
}
@Override
public void run() {
if (once.compareAndSet(false, true)) {
parent.emit(idx, value, this);
