Run message processing in background tasks

Author: Artem4590

meeseeks/core.py

@@ -137,10 +137,10 @@ def _init_apps(self) -> list[_T]:
 
         return app_instances
 
-    async def loop(self) -> None:
-        """Method is intended for calling in endless loop to process Rocket.Chat callbacks. """
+    async def message_handler(self, message) -> None:
+        """Serializes message context and run processing for each app. """
 
-        raw_context: WebSocketClientProtocol = json.loads(await self._websocket.recv())
+        raw_context: WebSocketClientProtocol = json.loads(message)
         if raw_context.get('msg') == 'ping':
             await self._rtapi.pong()
             return None
@@ -193,9 +193,11 @@ async def run(self) -> None:
                 self.check_app_name(app)
                 await app.setup()
 
-            while True:
+            async for message in websocket:
                 try:
-                    await self.loop()
+                    task = asyncio.create_task(self.message_handler(message))
+                    background_tasks = {task}
+                    task.add_done_callback(background_tasks.discard)
                 except ClientResponseError as exc:
                     LOGGER.error(exc)
                 except ConnectionClosedOK: