diff --git a/ssb/muxrpc.py b/ssb/muxrpc.py
index f121e13..f48ad15 100644
--- a/ssb/muxrpc.py
+++ b/ssb/muxrpc.py
@@ -159,11 +159,11 @@ class MuxRPCAPI:
         """Continuously process incoming messages"""
 
         async for req_message in self.connection:
-            body = req_message.body
-
             if req_message is None:
                 return
 
+            body = req_message.body
+
             if isinstance(body, dict) and body.get("name"):
                 self.process(self.connection, MuxRPCRequest.from_message(req_message))