如何在类和现有事件循环中将Python的websocket与asyncio一起使用

我目前正在尝试将websocket界面集成到我的程序中。为此，我正在使用https://websockets.readthedocs.io/en/stable/intro.html模块以及asyncio。我目前正在努力在专用类中实现websocket功能，该类将websocket任务设置为在与MyDriver类中运行的任务相同的事件循环中并发运行。

main.py

from myDriver import MyDriver
from webSocketServer import WebSocketServer

async def main():

   # loop = asyncio.get_event_loop()
   driver = MyDriver()
   ws = WebSocketServer()
   await driver.drive()
   # The following does not integrate properly with the above. The msgHandler is not ran 
   await websockets.serve(lambda websocket, path: ws.msgHandler(websocket, path), "localhost", 5678)

asyncio.run(main())

这里的lambda摆脱了来自类的自我争论。

webSocketServer.py

import asyncio
import websockets

class WebSocketServer:

    def __init__(self):
        print('Init')

    async def msgHandler(self, websocket, path):
        self.sendTask = asyncio.create_task(self.sendHandler(websocket, path))
        self.receiveTask = asyncio.create_task(self.receiveHandler(websocket, path))

        await asyncio.wait([self.sendTask, self.receiveTask], return_when=asyncio.FIRST_COMPLETED)

    async def sendHandler(self, websocket, path):
        while True:
            await asyncio.sleep(2)
            message = producer()
            await websocket.send(message)

    async def receiveHandler(self, websocket, path):
        async for message in websocket:
            await self.printMsg()

    async def printMsg(self, msg):
        await asyncio.sleep(0.1)
        print(msg)

    def producer():
        return 'Hi !'

我的实现基于websockets入门页面上提供的示例。他们使用loop.run_until_complete(server)＆loop.run_forever()API。我还尝试通过将loopin参数传递给的构造函数来使用它们，WebSocketServer(loop)并在websockets.serve(lambda websocket, path: ws.msgHandler(websocket, path), "localhost", 5678)那里进行操作，但随后出现错误RuntimeError: This event loop is already running。我还查看了loop.create_task()，其中将协程作为参数。

有没有人看到我可以正确集成与我的其他任务在同一事件循环中运行的websocket服务器的方法？谢谢 ！