Function stream_sse_chunks

examples/server/server.py:15830–15864

(
        formatter: OpenAIFormatter,
        http_request: Request,
        stream: CompletionStream,
        cancel: Callable[[], None],
        chunk_payloads: Callable[[CompletionChunk], Iterable[Any]],
    )

                stream.close()

    async def stream_sse_chunks(
        formatter: OpenAIFormatter,
        http_request: Request,
        stream: CompletionStream,
        cancel: Callable[[], None],
        chunk_payloads: Callable[[CompletionChunk], Iterable[Any]],
    ) -> AsyncIterator[bytes]:
        disconnect_task = asyncio.create_task(
            watch_http_disconnect(http_request, cancel)
        )
        try:
            while True:
                done, chunk = await asyncio.to_thread(
                    formatter.next_stream_chunk,
                    stream,
                )
                if done:
                    break
                assert chunk is not None
                for payload in chunk_payloads(chunk):
                    yield formatter.encode_sse_payload(payload)
            yield b"data: [DONE]\n\n"
        except asyncio.CancelledError:
            cancel()
            raise
        except BaseException as exc:
            cancel()
            if (
                isinstance(exc, CompletionRequestCancelledError)
                and await http_request.is_disconnected()
            ):
                return
            raise
        finally:
            disconnect_task.cancel()

    async def stream_sse_outputs(
        formatter: OpenAIFormatter,