Method flushInternal

src/audio_decoder.ts:291–325

(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);

		// Send null packet to signal flush
		const ret = await this.codecContext.sendPacket(null);
		if (ret < 0) {
			throw new DOMException('Flush failed', 'EncodingError');
		}

		// Keep receiving frames until no more are available
		while (true) {
			const receiveRet = await this.codecContext.receiveFrame(this.frame);
			if (receiveRet < 0) {
				// No more frames available
				break;
			}

			this.outputData(configId);
		}

		this.codecContext.flushBuffers();

		// 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 decoder and releases all resources.