diff options
Diffstat (limited to 'runtime/js')
| -rw-r--r-- | runtime/js/11_workers.js | 6 | ||||
| -rw-r--r-- | runtime/js/99_main.js | 4 |
2 files changed, 5 insertions, 5 deletions
diff --git a/runtime/js/11_workers.js b/runtime/js/11_workers.js index 2f9413119..f01dc3d5f 100644 --- a/runtime/js/11_workers.js +++ b/runtime/js/11_workers.js @@ -284,11 +284,11 @@ while (!this.terminated) { const data = await hostRecvMessage(this.#id); if (data === null) break; - let message, transfer; + let message, transferables; try { const v = deserializeJsMessageData(data); message = v[0]; - transfer = v[1]; + transferables = v[1]; } catch (err) { const event = new MessageEvent("messageerror", { cancelable: false, @@ -300,7 +300,7 @@ const event = new MessageEvent("message", { cancelable: false, data: message, - ports: transfer, + ports: transferables.filter((t) => t instanceof MessagePort), }); this.dispatchEvent(event); } diff --git a/runtime/js/99_main.js b/runtime/js/99_main.js index af6309338..fc3eeecca 100644 --- a/runtime/js/99_main.js +++ b/runtime/js/99_main.js @@ -135,12 +135,12 @@ delete Object.prototype.__proto__; if (data === null) break; const v = deserializeJsMessageData(data); const message = v[0]; - const transfer = v[1]; + const transferables = v[1]; const msgEvent = new MessageEvent("message", { cancelable: false, data: message, - ports: transfer, + ports: transferables.filter((t) => t instanceof MessagePort), }); try { |