Update app.py

app.py

@@ -43,7 +43,6 @@ async def proxy_handler(url: str, request: Request):
         body = await request.body()
         
         async with await get_http_client() as client:
-            # 判断是否需要流式传输
             if await is_stream_request(request):
                 # 流式请求
                 response = await client.stream(
@@ -61,8 +60,11 @@ async def proxy_handler(url: str, request: Request):
 
                 async def stream_generator():
                     try:
-                        async for chunk in response.aiter_bytes():
-                            yield chunk
+                        buffer = b""
+                        async for chunk in response.aiter_raw():
+                            # 立即发送每个收到的块
+                            if chunk:
+                                yield chunk
                     except Exception as e:
                         print(f"Streaming error: {e}")
                     finally: