Skip to content

Commit 5ffc674

Browse files
themighty1sinui0
andauthored
fix(web-spawn): call thread destructor (#68)
* fix(web-spawn): call thread destructor * simpler --------- Co-authored-by: sinu <[email protected]>
1 parent 98da844 commit 5ffc674

File tree

3 files changed

+13
-5
lines changed

3 files changed

+13
-5
lines changed

web-spawn/Cargo.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[package]
22
name = "web-spawn"
3-
version = "0.2.0"
3+
version = "0.2.1"
44
edition = "2024"
55
description = "`std` spawn replacement for WASM in the browser."
66
repository = "https://github.com/tlsnotary/tlsn-utils"

web-spawn/js/spawn.js

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,12 +17,14 @@ registerMessageListener(self, 'web_spawn_start_spawner', async (data) => {
1717
);
1818
const [module, memory, spawnerPtr] = data;
1919
const pkg = await import('../../..');
20-
await pkg.default({ module, memory });
20+
const exports = await pkg.default({ module, memory });
2121

2222
const spawner = pkg.web_spawn_recover_spawner(spawnerPtr);
2323
postMessage('web_spawn_spawner_ready');
2424
await spawner.run(workerUrl.toString());
2525

26+
exports.__wbindgen_thread_destroy();
27+
2628
close();
2729
});
2830

@@ -31,10 +33,12 @@ registerMessageListener(self, 'web_spawn_start_worker', async (data) => {
3133
const [module, memory, workerPtr] = data;
3234

3335
const pkg = await import('../../..');
34-
await pkg.default({ module, memory });
36+
const exports = await pkg.default({ module, memory });
3537

3638
pkg.web_spawn_start_worker(workerPtr);
3739

40+
exports.__wbindgen_thread_destroy();
41+
3842
close();
3943
});
4044

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,12 @@ registerMessageListener(self, 'web_spawn_start_spawner', async (data) => {
1414
const [module, memory, workerUrl, wasmUrl, spawner] = data;
1515
const wasm = await import(`${wasmUrl}`);
1616

17-
wasm.initSync({ module, memory });
17+
const exports = wasm.initSync({ module, memory });
1818
postMessage('web_spawn_spawner_ready');
1919
await wasm.web_spawn_recover_spawner(spawner).run(workerUrl);
2020

21+
exports.__wbindgen_thread_destroy();
22+
2123
URL.revokeObjectURL(workerUrl);
2224

2325
close();
@@ -28,9 +30,11 @@ registerMessageListener(self, 'web_spawn_start_worker', async (data) => {
2830
const [module, memory, wasmUrl, worker] = data;
2931
const wasm = await import(`${wasmUrl}`);
3032

31-
wasm.initSync({ module, memory });
33+
const exports = wasm.initSync({ module, memory });
3234
wasm.web_spawn_start_worker(worker);
3335

36+
exports.__wbindgen_thread_destroy();
37+
3438
close();
3539
});
3640

0 commit comments

Comments
 (0)