mercuryworkshop-mirror/scramjet
1
0
Fork 0
mirror of https://github.com/MercuryWorkshop/scramjet.git synced 2025-05-16 15:40:02 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

prettier

Browse source
This commit is contained in:
Percs 2024-07-16 17:42:21 -05:00
parent fa779017ad
commit d6dd1d4ca3
20 changed files with 363 additions and 379 deletions
Download patch file Download diff file Expand all files Collapse all files

60
src/thread/thread.ts
View file

@ -1,46 +1,40 @@
import { rewriteJs } from "../shared/rewriters/js";
// @ts-ignore
onconnect = (e) => {
const port = e.ports[0];
const port = e.ports[0];
console.log("thread: connected to port", port);
port.postMessage("ready");
console.log("thread: connected to port", port)
port.postMessage("ready");
let syncToken = 0;
port.onmessage = ({ data }) => {
console.log("thread: received message", data);
const [task, ...args] = data;
let token = syncToken++;
let syncToken = 0;
port.onmessage = ({ data }) => {
console.log("thread: received message", data)
const [task, ...args] = data;
let token = syncToken++;
try {
let res = tasks[task](...args);
console.log("thread: task", task, "completed with token", token)
port.postMessage({
token,
result: res
})
} catch (e) {
port.postMessage({
token,
error: e.message
})
}
port.postMessage("idle");
}
}
try {
let res = tasks[task](...args);
console.log("thread: task", task, "completed with token", token);
port.postMessage({
token,
result: res,
});
} catch (e) {
port.postMessage({
token,
error: e.message,
});
}
port.postMessage("idle");
};
};
const tasks = {
"rewriteJs": taskRewriteJs,
}
rewriteJs: taskRewriteJs,
};
function taskRewriteJs(js: ArrayBuffer, origin: string): string {
return rewriteJs(js, new URL(origin));
return rewriteJs(js, new URL(origin));
}