(worker: SharedWorker, msg: any)
| 265 | }) |
| 266 | |
| 267 | function sendEventMessage(worker: SharedWorker, msg: any) { |
| 268 | return new Promise<string>((resolve, reject) => { |
| 269 | const timeout = setTimeout(() => { |
| 270 | reject(new Error(`Failed to send the message ${msg} to the SharedWorker.`)) |
| 271 | }, 5_000) |
| 272 | worker.port.addEventListener('message', function onmessage(e) { |
| 273 | worker.port.removeEventListener('message', onmessage) |
| 274 | clearTimeout(timeout) |
| 275 | resolve(e.data as string) |
| 276 | }) |
| 277 | worker.port.postMessage(msg) |
| 278 | }) |
| 279 | } |
| 280 | |
| 281 | function sendOnMessage(worker: SharedWorker, msg: any) { |
| 282 | return new Promise<string>((resolve, reject) => { |
no test coverage detected