#include <nxtai/responses.hpp>
template <typename Transport>
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::.
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-streambody. -
auto next() → nxt::
task<std:: optional<stream_ event>> - Read the next decoded event, or
std::after stream end.nullopt -
auto operator=(const openai_
response_ stream&) → openai_ response_ stream& deleted -
auto operator=(openai_
response_ stream&&) → openai_ response_ stream& deleted