diff --git a/polypheny/rpc.py b/polypheny/rpc.py
index 7808b257..7753458f 100644
--- a/polypheny/rpc.py
+++ b/polypheny/rpc.py
@@ -57,6 +57,8 @@ def send_msg(self, serialized):
 
     def recv_msg(self):
         bl = self.con.recv(8)
+        if len(bl) != 8:
+            raise EOFError
         n = int.from_bytes(bl, 'little')
         raw = self.con.recv(n)
         if len(raw) != n: