Method stream_generator

core/storage.py:689–704

()

                pass
            
            async def stream_generator():
                try:
                    async with session.get(link) as resp:
                        if resp.status != 200:
                            raise HTTPException(
                                status_code=resp.status,
                                detail=f"从OneDrive获取文件失败: {resp.status}"
                            )
                        chunk_size = 65536
                        while True:
                            chunk = await resp.content.read(chunk_size)
                            if not chunk:
                                break
                            yield chunk
                finally:
                    await session.close()
            
            encoded_filename = quote(filename, safe='')
            headers = {