diff --git a/src/index.ts b/src/index.ts index 1f39079..1c5f5a6 100644 --- a/src/index.ts +++ b/src/index.ts @@ -433,6 +433,8 @@ async function handleSyncProtomux(aq: ActiveQuery) { return; } + debugger; + const mux = Protomux.from(socket); let mutex: Mutex | null = null; if (mux.mutex) { @@ -482,6 +484,8 @@ async function handleSyncProtomux(aq: ActiveQuery) { } aq.respond(ret); + + mutex.release(); } function getSwarmToSocketConnectionId(socket: any) {