[Bug] 异步路径中调用同步 requests(无超时),网络异常时冻结整个事件循环 #81

# stream.py:65 — async def start() 的事件循环里直接同步调用
connection = self.open_connection()

# stream.py:172 — open_connection() 内部,同步 requests 且无 timeout
response = requests.post(DingTalkStreamClient.OPEN_CONNECTION_API,
                         headers=request_headers,
                         data=request_body)

# card_replier.py — async_create_and_send_card / async_streaming /
# async_put_card_data 等异步方法开头均为:
access_token = self.dingtalk_client.get_access_token()

# stream.py:217 — get_access_token() 内部,同样是无 timeout 的 requests.post
response = requests.post(url, headers=request_headers, data=json.dumps(values))

import asyncio
from dingtalk_stream import Credential, DingTalkStreamClient

async def main():
    client = DingTalkStreamClient(Credential("fake", "fake"))
    task = asyncio.create_task(client.start())
    await asyncio.sleep(1)
    task.cancel()
    # 网络不通时 cancel 无法打断阻塞中的 requests.post,这里超时
    await asyncio.wait_for(task, timeout=5)

asyncio.run(main())