diff --git a/src/index.ts b/src/index.ts index eacb615..2769296 100644 --- a/src/index.ts +++ b/src/index.ts @@ -455,7 +455,9 @@ async function handleSyncProtomux(aq: ActiveQuery) { } }); mux._free = mux._free.filter((item: any) => item !== undefined); + socket.off("syncProtomux", sync); socket.emit("syncProtomux"); + socket.on("syncProtomux", sync); mutex.release(); });