[feat] DeasyncEndpoint

[loynoir]

Usage

const dohMathSync = api.doMathAsync.bind(api)

main.mjs

import { Worker } from 'worker_threads'
import * as Comlink from 'comlink'

const worker = new Worker(new URL('./worker.mjs', import.meta.url))
const api = Comlink.wrap(Comlink.DeasyncEndpoint(worker))

const dohMathSync = api.doMathAsync.bind(api)

worker.mjs

import { parentPort } from 'worker_threads'
import * as Comlink from 'comlink'

const api = {
  async doMathAsync() {
    return 4
  }
}

Comlink.expose(api, Comlink.DeasyncEndpoint(parentPort))

Description

I think DeasyncEndpoint is possible.

But I don't know how to wrap comlink with SharedArrayBuffer and Atomics.wait.

https://github.com/un-ts/synckit/blob/v0.8.5/src/index.ts#L340-L346

    const sharedBuffer = new SharedArrayBuffer(bufferSize)
    const sharedBufferView = new Int32Array(sharedBuffer)

    const msg: MainToWorkerMessage<Parameters<T>> = { sharedBuffer, id, args }
    worker.postMessage(msg)

    const status = Atomics.wait(sharedBufferView, 0, 0, timeout)

[alexmojaki]

Sounds like you would find https://github.com/pyodide/synclink useful. cc @hoodmane

[loynoir]

@alexmojaki

Thanks for the link.

Seems it is what I want.