()
| 463 | ) |
| 464 | |
| 465 | async def generate_json_chunks(): |
| 466 | chunk_size = 8192 # 8KB chunks |
| 467 | for i in range(0, len(response_json_str), chunk_size): |
| 468 | chunk = response_json_str[i : i + chunk_size] |
| 469 | yield chunk |
| 470 | await asyncio.sleep(0.01) |
| 471 | |
| 472 | result_future.set_result( |
| 473 | StreamingResponse( |
no outgoing calls
no test coverage detected