diff --git a/src/index.ts b/src/index.ts index 0daea8d..564176d 100644 --- a/src/index.ts +++ b/src/index.ts @@ -165,8 +165,7 @@ function handleSocketListenEvent(aq: ActiveQuery) { aq.respond(); }; - const cb = async (data: Buffer) => { - await socket.mutex?.waitForUnlock(); + const cb = (data: Buffer) => { if (responded) { return; }