synchronized (this) {
                    skipFinal = true;
                    if (!missed) {
                        emitting = false;
                        return;