diff --git a/analytics/analytics/services/server_service.py b/analytics/analytics/services/server_service.py
index 8a957ba..a47a364 100644
--- a/analytics/analytics/services/server_service.py
+++ b/analytics/analytics/services/server_service.py
@@ -58,8 +58,7 @@ class ServerService:
 
     async def __anext__(self) -> ServerMessage:
         while True:
-            received_bytes = await self.socket.recv()
-            text = received_bytes.decode('utf-8')
+            text = await self.socket.recv_string()
 
             if text == 'PING':
                 asyncio.ensure_future(self.__handle_ping())