def _dispatch_msg_async(msg):
async def _dispatch_msg(msg):
await self._router.send_multipart(msg)
asyncio.ensure_future(_dispatch_msg(msg))
微信
公众号
扫码关注公众号