diff --git a/src/rpc.ts b/src/rpc.ts
index 60dd2b3..b33c9ed 100644
--- a/src/rpc.ts
+++ b/src/rpc.ts
@@ -246,7 +246,17 @@ export async function start() {
 
   (await getDHT("server")).on("connection", (socket: any) => {
     socket.rawStream._ondestroy = () => false;
-    socket.on("data", async (data: any) => {
+
+    let isRpc = false;
+    socket.once("data", async (data: any) => {
+      if (data === "rpc") {
+        isRpc = true;
+      }
+    });
+    socket.once("data", async (data: any) => {
+      if (!isRpc) {
+        return;
+      }
       let request: RPCRequest;
       try {
         request = unpack(data) as RPCRequest;