template <typename Transport>
nxt::ai::responses::openai_response_stream class

Pull-shaped OpenAI Responses SSE stream.

Construct with a connected transport, call connect() once to send the request and validate the response head, then drive the stream by calling next() until it returns std::nullopt.

Constructors, destructors, conversion operators

openai_response_stream(Transport& transport, std::stop_token stop = {}) explicit
Bind the stream to an already-connected byte transport.
openai_response_stream(const openai_response_stream&) deleted
openai_response_stream(openai_response_stream&&) deleted

Public functions

auto connect(const openai_responses_request& request) →  nxt::task
Send the request and prepare to read its text/event-stream body.
auto next() →  nxt::task<std::optional<stream_event>>
Read the next decoded event, or std::nullopt after stream end.
auto operator=(const openai_response_stream&) →  openai_response_stream& deleted
auto operator=(openai_response_stream&&) →  openai_response_stream& deleted