web-thread 0.2.2

Convenient Web worker threading library with transferable support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

// @ts-check

// Copyright (c) Zefchain Labs, Inc.
// SPDX-License-Identifier: Apache-2.0

// This must be made available by the library consumer, since we don't
// know where it is yet.
import * as wasm from 'web-thread:wasm-shim';

const pending = new Map();

self.onmessage = async (event) => {
  if (event.data.type === 'init') {
    await wasm.default(event.data);
    self.postMessage({ type: 'ready' });
  } else if (event.data.type === 'destroy') {
    for (const id of pending.keys())
      self.postMessage({ type: 'response', id, error: new Error('thread destroyed during execution') });
    self.close();
  } else if (event.data.type === 'run') {
    const { id, code, context } = event.data;
    pending.set(id, null);
    try {
      const { message: result, transfer } = await wasm.__web_thread_worker_entry_point(code, context);
      self.postMessage({ type: 'response', id, result }, transfer);
    } catch (error) {
      console.error(error);
      self.postMessage({ type: 'response', id, error });
    } finally {
      pending.delete(id);
    }
  } else {
    console.error('[web-thread] malformed request', event.data);
  }
}