* by functions in `async` module.
* @param {object} message.data - Worker commands and related data
*/
- function handleMessage (message: unknown): void {
- NODE: if (host == null) return queueMicrotask(() => handleMessage(message))
+ function listener (message: unknown): void {
+ NODE: if (host == null) return queueMicrotask(() => listener(message))
if (message == null
|| typeof message !== 'object'
|| !('data' in message)
NODE: host?.postMessage({ data })
}
}
- BROWSER: addEventListener('message', handleMessage)
+ BROWSER: addEventListener('message', listener)
NODE: {
if (host == null) {
import('node:worker_threads')
.then(({ parentPort }): void => {
host = parentPort
- host?.on('message', handleMessage)
+ host?.on('message', listener)
})
}
}