Method flush

src/audio_decoder.ts:270–289

* Flushes all pending decode operations and waits for completion.

()

	 * Flushes all pending decode operations and waits for completion.
	 */
	async flush() {
		// Spec: If [[state]] is not "configured", return a promise rejected with InvalidStateError DOMException.
		if (this._state !== 'configured') {
			return Promise.reject(new DOMException('Decoder not configured', 'InvalidStateError'));
		}

		// Spec: Set [[key chunk required]] to true.
		this._keyChunkRequired = true;

		// Spec: Let promise be a new Promise. Append promise to [[pending flush promises]].
		return new Promise<void>((resolve, reject) => {
			this._pendingFlushResolvers.push({ resolve, reject });

			// Spec: Queue a control message to flush the codec...
			this.flushInternal(this.currentConfigId, resolve).catch((e) => {
				// If flush fails, we treat it as an error that closes the decoder
				this.handleAsyncError(e);
			});
		});
	}

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