Merge pull request #5325 from remotion-dev/fix-webcodecs-queue-size-and-flush

Author: JonnyBurger

packages/webcodecs/src/reencode-audio-track.ts

@@ -230,7 +230,8 @@ export const reencodeAudioTrack = async ({
 	});
 
 	state.addWaitForFinishPromise(async () => {
-		await audioDecoder.waitForQueueToBeLessThan(0);
+		Log.verbose(logLevel, 'Waiting for audio decoder to finish');
+		await audioDecoder.flush();
 		Log.verbose(logLevel, 'Audio decoder finished');
 		audioDecoder.close();
 		await audioProcessingQueue.ioSynchronizer.waitForQueueSize(0);

packages/webcodecs/src/reencode-video-track.ts

@@ -205,8 +205,7 @@ export const reencodeVideoTrack = async ({
 
 	state.addWaitForFinishPromise(async () => {
 		Log.verbose(logLevel, 'Waiting for video decoder to finish');
-
-		await videoDecoder.waitForQueueToBeLessThan(0);
+		await videoDecoder.flush();
 		videoDecoder.close();
 		Log.verbose(
 			logLevel,
@@ -230,7 +229,7 @@ export const reencodeVideoTrack = async ({
 		);
 
 		await controller._internals._mediaParserController._internals.checkForAbortAndPause();
-		await videoDecoder.waitForQueueToBeLessThan(10);
+		await videoDecoder.waitForQueueToBeLessThan(15);
 
 		if (chunk.type === 'key') {
 			await videoDecoder.flush();