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