Method loop

fastdeploy/inter_communicator/fmq.py:305–311

()

            self._sub_socket.setsockopt_string(zmq.SUBSCRIBE, "")

        async def loop():
            while True:
                raw = await self._sub_socket.recv()
                msg = Message.deserialize(raw)
                result = callback(msg)
                if asyncio.iscoroutine(result):
                    await result

        self._task = asyncio.create_task(loop())