Fix transmuxer worker error forwarding (#7883)

* Fix transmuxer worker error forwarding (missing instanceNo)
Found testing #4958 with worker: "Containerless ec-3 is not supported"

* Add missing overserver teardown
This commit is contained in:
Rob Walch
2026-05-29 18:34:10 -07:00
committed by GitHub
parent d0d7b1f08b
commit f633b56e0e
2 changed files with 9 additions and 2 deletions
+6 -2
View File
@@ -30,8 +30,12 @@ function startWorker() {
if (data.cmd === 'init') {
const config = JSON.parse(data.config);
const observer = new EventEmitter();
observer.on(Events.FRAG_DECRYPTED, forwardMessage);
observer.on(Events.ERROR, forwardMessage);
observer.on(Events.FRAG_DECRYPTED, (event, data) =>
forwardMessage(event, data, instanceNo),
);
observer.on(Events.ERROR, (event, data) =>
forwardMessage(event, data, instanceNo),
);
const logger = enableLogs(config.debug, data.id);
forwardWorkerLogs(logger, instanceNo);
transmuxers[instanceNo] = new Transmuxer(
+3
View File
@@ -363,6 +363,9 @@ export default class Transmuxer {
this.remuxer.destroy();
this.remuxer = undefined;
}
if (this.observer) {
this.observer.removeAllListeners();
}
this.decryptionPromise = null;
this.decrypter = this.observer = undefined;
//@ts-ignore