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

make logs a bit more descriptive

Browse source
This commit is contained in:
Toshit Chawda 2024-07-08 13:01:13 -07:00
parent 6e86375a69
commit 2169a423b6
No known key found for this signature in database
GPG key ID: 91480ED99E2B3D9D
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/connection.ts
View file

@ -142,7 +142,7 @@ export class WorkerConnection {
try { try {
await pingPromise; await pingPromise;
} catch { } catch {
console.warn("Failed to get a ping response from the worker within 1.5s. Assuming port is dead."); console.warn("bare-mux: Failed to get a ping response from the worker within 1.5s. Assuming port is dead.");
this.createChannel(); this.createChannel();
return await this.sendMessage(message, transferable); return await this.sendMessage(message, transferable);
} }

6
src/worker.ts
View file

@ -33,7 +33,7 @@ function handleConnection(port: MessagePort) {
port.postMessage(<WorkerResponse>{ type: "set" }); port.postMessage(<WorkerResponse>{ type: "set" });
} catch (err) { } catch (err) {
console.error(err); console.error("error while processing 'set': ", err);
port.postMessage(<WorkerResponse>{ type: "error", error: err }); port.postMessage(<WorkerResponse>{ type: "error", error: err });
} }
} else if (message.type === "get") { } else if (message.type === "get") {
@ -57,7 +57,7 @@ function handleConnection(port: MessagePort) {
port.postMessage(<WorkerResponse>{ type: "fetch", fetch: resp }); port.postMessage(<WorkerResponse>{ type: "fetch", fetch: resp });
} }
} catch (err) { } catch (err) {
console.error(err); console.error("error while processing 'fetch': ", err);
port.postMessage(<WorkerResponse>{ type: "error", error: err }); port.postMessage(<WorkerResponse>{ type: "error", error: err });
} }
} else if (message.type === "websocket") { } else if (message.type === "websocket") {
@ -101,7 +101,7 @@ function handleConnection(port: MessagePort) {
port.postMessage(<WorkerResponse>{ type: "websocket" }); port.postMessage(<WorkerResponse>{ type: "websocket" });
} catch (err) { } catch (err) {
console.error(err); console.error("error while processing 'websocket': ", err);
port.postMessage(<WorkerResponse>{ type: "error", error: err }); port.postMessage(<WorkerResponse>{ type: "error", error: err });
} }
} }