diff --git a/ssb/muxrpc.py b/ssb/muxrpc.py
index 57f3d04..eefd934 100644
--- a/ssb/muxrpc.py
+++ b/ssb/muxrpc.py
@@ -138,10 +138,11 @@ class MuxRPCAPI:
 
     async def __await__(self):
         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))