用法

importasyncioimportdanmakuasyncdefprinter(q):whileTrue:m=awaitq.get()print(m)asyncdefmain():q=asyncio.Queue()dmc=danmaku.DanmakuClient('https://douyu.com/9999',q)asyncio.create_task(printer(q))awaitdmc.start()asyncio.run(main())