diff --git a/src/connection.ts b/src/connection.ts index a092b31..fdff6de 100644 --- a/src/connection.ts +++ b/src/connection.ts @@ -142,7 +142,7 @@ export class WorkerConnection { try { await pingPromise; } 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(); return await this.sendMessage(message, transferable); } diff --git a/src/worker.ts b/src/worker.ts index c9fa6f1..70ddc31 100644 --- a/src/worker.ts +++ b/src/worker.ts @@ -33,7 +33,7 @@ function handleConnection(port: MessagePort) { port.postMessage({ type: "set" }); } catch (err) { - console.error(err); + console.error("error while processing 'set': ", err); port.postMessage({ type: "error", error: err }); } } else if (message.type === "get") { @@ -57,7 +57,7 @@ function handleConnection(port: MessagePort) { port.postMessage({ type: "fetch", fetch: resp }); } } catch (err) { - console.error(err); + console.error("error while processing 'fetch': ", err); port.postMessage({ type: "error", error: err }); } } else if (message.type === "websocket") { @@ -101,7 +101,7 @@ function handleConnection(port: MessagePort) { port.postMessage({ type: "websocket" }); } catch (err) { - console.error(err); + console.error("error while processing 'websocket': ", err); port.postMessage({ type: "error", error: err }); } }