Method flushInternal

src/audio_encoder.ts:590–618

(configId: number, resolve: () => void)

	}

	private async flushInternal(configId: number, resolve: () => void) {
		using lock = this.mutex.lock();
		if (lock.pending) await lock.ready;

		if (this.currentConfigId !== configId) {
			// Reset/Close happened, promise already rejected
			return;
		}

		assert(this.codecContext);

		// Drain any remaining samples from the resampler
		if (this.resampler && this.dstFrame && this.codecContext.frameSize > 0) {
			await this.pullResampledFrames(configId, true);
		}

		// Signal flush to the encoder
		await this.sendFrameAndReceivePackets(null, configId);

		this.codecContext.flushBuffers();
		this.chunkOutputted = false;
		this.nextPts = 0n;
		this.resampledSampleCount = 0;

		// Spec: Remove promise from [[pending flush promises]]. Resolve promise.
		const index = this.pendingFlushResolvers.findIndex(p => p.resolve === resolve);
		if (index !== -1) this.pendingFlushResolvers.splice(index, 1);
		resolve();
	}

	/**
	 * Closes the encoder and releases all resources.