call handlers with await

gildas-lormeau · Jan 27, 2024 · 54b133f · 54b133f
1 parent 4bd65d1
commit 54b133f
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/lib/core/codec-worker.js b/lib/core/codec-worker.js
@@ -100,9 +100,9 @@ class ProgressWatcherStream extends TransformStream {
 	constructor(readableSource, { onstart, onprogress, size, onend }) {
 		let chunkOffset = 0;
 		super({
-			start() {
+			async start() {
 				if (onstart) {
-					callHandler(onstart, size);
+					await callHandler(onstart, size);
 				}
 			},
 			async transform(chunk, controller) {
@@ -112,10 +112,10 @@ class ProgressWatcherStream extends TransformStream {
 				}
 				controller.enqueue(chunk);
 			},
-			flush() {
+			async flush() {
 				readableSource.size = chunkOffset;
 				if (onend) {
-					callHandler(onend, chunkOffset);
+					await callHandler(onend, chunkOffset);
 				}
 			}
 		});