31 lines
629 B
JavaScript
31 lines
629 B
JavaScript
export default function(source) {
|
|
const worker = new Worker(source);
|
|
let counter = 0;
|
|
let handlers = {};
|
|
|
|
worker.addEventListener("message", event => {
|
|
const { uid, message, error } = event.data;
|
|
|
|
if (!handlers[uid]) return;
|
|
|
|
const [resolve, reject] = handlers[uid];
|
|
delete handlers[uid];
|
|
|
|
if (error) {
|
|
reject(error);
|
|
} else {
|
|
resolve(message);
|
|
}
|
|
});
|
|
|
|
return {
|
|
postMessage(message) {
|
|
const uid = ++counter;
|
|
return new Promise((resolve, reject) => {
|
|
handlers[uid] = [resolve, reject];
|
|
worker.postMessage({ uid, message });
|
|
});
|
|
}
|
|
};
|
|
}
|