fix: Destroying execution environment streams should emit events

FrederikBolding · FrederikBolding · commit 06b355d1b87b · 2025-08-05T13:11:10.000+02:00
diff --git a/packages/snaps-controllers/src/services/AbstractExecutionService.ts b/packages/snaps-controllers/src/services/AbstractExecutionService.ts
@@ -193,8 +193,7 @@ export abstract class AbstractExecutionService<WorkerType>
 
     Object.values(job.streams).forEach((stream) => {
       try {
-        !stream.destroyed && stream.destroy();
-        stream.removeAllListeners();
+        stream.destroy();
       } catch (error) {
         logError('Error while destroying stream', error);
       }

Original file line number	Diff line number	Diff line change
`@@ -193,8 +193,7 @@ export abstract class AbstractExecutionService<WorkerType>`
`193`	`193`
`194`	`194`	`Object.values(job.streams).forEach((stream) => {`
`195`	`195`	`try {`
`196`		`- !stream.destroyed && stream.destroy();`
`197`		`- stream.removeAllListeners();`
	`196`	`+ stream.destroy();`
`198`	`197`	`} catch (error) {`
`199`	`198`	`logError('Error while destroying stream', error);`
`200`	`199`	`}`