Function collect_completion_results

examples/server/server.py:15790–15828

(
        formatter: OpenAIFormatter,
        http_request: Request,
        submissions: Sequence[
            Tuple[
                CompletionStream,
                Callable[[], None],
            ]
        ],
    )

            stream.close()

    async def collect_completion_results(
        formatter: OpenAIFormatter,
        http_request: Request,
        submissions: Sequence[
            Tuple[
                CompletionStream,
                Callable[[], None],
            ]
        ],
    ) -> List[OpenAICompletion] | Response:
        streams = [stream for stream, _ in submissions]
        cancel_all = [cancel for _, cancel in submissions]

        def cancel_all_requests() -> None:
            for cancel in cancel_all:
                cancel()

        disconnect_task = asyncio.create_task(
            watch_http_disconnect(
                http_request,
                cancel_all_requests,
            )
        )
        try:
            return await asyncio.gather(
                *(
                    asyncio.to_thread(formatter.collect_completion, stream)
                    for stream in streams
                )
            )
        except asyncio.CancelledError:
            cancel_all_requests()
            raise
        except BaseException as exc:
            return await disconnected_cancelled_response_or_raise(http_request, exc)
        finally:
            disconnect_task.cancel()
            for stream in streams:
                stream.close()

    async def stream_sse_chunks(
        formatter: OpenAIFormatter,