github-repos/blive
1
0
Fork 0
mirror of https://github.com/yulinfeng000/blive.git synced 2025-03-25 16:50:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

获取房间信息，获取直播间ws地址改为异步请求/hotfix

Browse Source
This commit is contained in:
Cam 2023-01-30 22:30:43 +08:00
parent 852f299f1b
commit 07380a48db
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
blive/eeframework.py
View File

@ -39,7 +39,6 @@ class BLiver(AsyncIOEventEmitter):
self.aio_session = aiohttp.ClientSession()
self.packman = BLiveMsgPackage()
self.scheduler = AsyncIOScheduler(timezone="Asia/ShangHai")
self.aio_session = aiohttp.ClientSession()
def register_handler(self, event: Union[Events, List[Events]], handler):
warnings.warn(
@ -64,7 +63,7 @@ class BLiver(AsyncIOEventEmitter):
await self.connect() # 重新连接
async def connect(self, retries=5):
for _ in range(retries):
for i in range(retries):
try:
if not hasattr(self,"real_room_id") or not hasattr(self,"uname"):
self.real_room_id, self.uname = await get_blive_room_info(
@ -85,9 +84,9 @@ class BLiver(AsyncIOEventEmitter):
asyncio.TimeoutError,
ConnectionError,
ConnectionResetError,
):
):
await asyncio.sleep(1)
raise aiohttp.ClientConnectionError("与服务器连接失败")
# raise aiohttp.ClientConnectionError("与服务器连接失败")
async def listen(self):
self.running = True
@ -138,4 +137,4 @@ class BLiver(AsyncIOEventEmitter):
def run_as_task(self):
loop = asyncio.get_event_loop()
return loop.create_task(self.listen())
return loop.create_task(self.listen())