fix(web-spawn): call thread destructor

web-spawn/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "web-spawn"
-version = "0.2.0"
+version = "0.2.1"
 edition = "2024"
 description = "`std` spawn replacement for WASM in the browser."
 repository = "https://github.com/tlsnotary/tlsn-utils"

web-spawn/js/spawn.js

@@ -17,12 +17,14 @@ registerMessageListener(self, 'web_spawn_start_spawner', async (data) => {
     );
     const [module, memory, spawnerPtr] = data;
     const pkg = await import('../../..');
-    await pkg.default({ module, memory });
+    const exports = await pkg.default({ module, memory });
 
     const spawner = pkg.web_spawn_recover_spawner(spawnerPtr);
     postMessage('web_spawn_spawner_ready');
     await spawner.run(workerUrl.toString());
 
+    exports.__wbindgen_thread_destroy();
+
     close();
 });
 
@@ -31,10 +33,12 @@ registerMessageListener(self, 'web_spawn_start_worker', async (data) => {
     const [module, memory, workerPtr] = data;
 
     const pkg = await import('../../..');
-    await pkg.default({ module, memory });
+    const exports = await pkg.default({ module, memory });
 
     pkg.web_spawn_start_worker(workerPtr);
 
+    exports.__wbindgen_thread_destroy();
+
     close();
 });
 

web-spawn/js/spawn.no-bundler.js

@@ -14,10 +14,12 @@ registerMessageListener(self, 'web_spawn_start_spawner', async (data) => {
     const [module, memory, workerUrl, wasmUrl, spawner] = data;
     const wasm = await import(`${wasmUrl}`);
 
-    wasm.initSync({ module, memory });
+    const exports = wasm.initSync({ module, memory });
     postMessage('web_spawn_spawner_ready');
     await wasm.web_spawn_recover_spawner(spawner).run(workerUrl);
 
+    exports.__wbindgen_thread_destroy();
+
     URL.revokeObjectURL(workerUrl);
 
     close();
@@ -28,9 +30,11 @@ registerMessageListener(self, 'web_spawn_start_worker', async (data) => {
     const [module, memory, wasmUrl, worker] = data;
     const wasm = await import(`${wasmUrl}`);
 
-    wasm.initSync({ module, memory });
+    const exports = wasm.initSync({ module, memory });
     wasm.web_spawn_start_worker(worker);
 
+    exports.__wbindgen_thread_destroy();
+
     close();
 });