mercuryworkshop-mirror/bare-mux
1
0
Fork 0
mirror of https://github.com/MercuryWorkshop/bare-mux.git synced 2025-05-14 14:50:03 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

make set transport async for the user

Browse source
This commit is contained in:
Toshit Chawda 2024-07-07 14:21:04 -07:00
parent 7a1273e967
commit 8ed59e901d
No known key found for this signature in database
GPG key ID: 91480ED99E2B3D9D
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

4
README.md
View file

@ -43,10 +43,10 @@ Here is an example of using bare-mux:
import { BareMuxConnection } from "@mercuryworkshop/bare-mux"; import { BareMuxConnection } from "@mercuryworkshop/bare-mux";
const conn = new BareMuxConnection("/bare-mux/worker.js"); const conn = new BareMuxConnection("/bare-mux/worker.js");
// Set Bare-Client transport // Set Bare-Client transport
await conn.setTransport(`return (async ()=>{ await conn.setTransport(`
const exports = await import("/bare-mux/index.js"); const exports = await import("/bare-mux/index.js");
return new exports.BareClient("https://tomp.app"); return new exports.BareClient("https://tomp.app");
})()`); `);
/// As a proxy developer /// As a proxy developer
import { BareClient } from "@mercuryworkshop/bare-mux"; import { BareClient } from "@mercuryworkshop/bare-mux";

2
src/worker.ts
View file

@ -8,7 +8,7 @@ function handleConnection(port: MessagePort) {
const port = event.data.port; const port = event.data.port;
const message: WorkerMessage = event.data.message; const message: WorkerMessage = event.data.message;
if (message.type === "set") { if (message.type === "set") {
const func = new Function(message.client); const func = new Function("return (async ()=>{" + message.client + "})()");
currentTransport = await func(); currentTransport = await func();
console.log("set transport to ", currentTransport); console.log("set transport to ", currentTransport);
port.postMessage(<WorkerResponse>{ type: "set" }); port.postMessage(<WorkerResponse>{ type: "set" });