Method flush

src/video_decoder.ts:321–340

* Flushes all pending decode operations and waits for completion.

()

	 * Flushes all pending decode operations and waits for completion.
	 */
	async flush() {
		// Spec 4.5: 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 4.5: Set [[key chunk required]] to true.
		this.keyChunkRequired = true;

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

			// Spec 4.5: 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();