cpp_restapi::ThreadedConnection Class Reference

BaseConnection subclass that implements fetch(url, cb) via a background std::thread. More...

#include <threaded_connection.hpp>

Inheritance diagram for cpp_restapi::ThreadedConnection:

Public Member Functions
	~ThreadedConnection () override
	BaseConnection (const std::string &address, const std::map< std::string, std::string > &headerEntries)
std::expected< std::string, HttpError >	fetch (const std::string &request) final
	Perform a single HTTP request.
std::expected< std::string, HttpError >	fetch (const std::string &request, IPaginationStrategy &strategy) final
	Perform requests with automatic pagination.
CancellationToken	fetch (const std::string &request, FetchCallback onSuccess, ErrorCallback onError={}) final
	Perform an HTTP GET request asynchronously.
CancellationToken	fetch (const std::string &request, IPaginationStrategy &strategy, BodyCallback onSuccess, ErrorCallback onError={}) final
	Perform paginated requests asynchronously.
Public Member Functions inherited from cpp_restapi::BaseConnection
	BaseConnection (const std::string &address, const std::map< std::string, std::string > &headerEntries)
const std::string &	url () const final
	return API url
std::expected< Response, HttpError >	fetchResponse (const std::string &url) final
	Perform a single HTTP request returning the full response.
std::string	get (const std::string &) final
	perform a request to api
virtual Response	fetchPage (const std::string &request)=0
Public Member Functions inherited from cpp_restapi::IConnection
virtual	~IConnection ()=default
virtual std::unique_ptr< ISseConnection >	subscribe (const std::string &request, EventCallback callback)=0
	Subscribe to an SSE endpoint.

Protected Member Functions
void	fetchAsync (const std::string &fullUrl, CancellationToken cancel, FetchCallback onSuccess, ErrorCallback onError) override
void	waitForPending ()
Protected Member Functions inherited from cpp_restapi::BaseConnection
const std::map< std::string, std::string > &	getHeaderEntries () const
const std::string &	address () const

Additional Inherited Members
Public Types inherited from cpp_restapi::IConnection
using	EventCallback = std::function<void(const SseEvent&)>
using	FetchCallback = std::function<void(Response)>
using	BodyCallback = std::function<void(std::string)>
using	ErrorCallback = std::function<void(HttpError)>

Detailed Description

BaseConnection subclass that implements fetch(url, cb) via a background std::thread.

Non-Qt backends (CppHttplib, Curl) inherit from this class to get a thread-based async fetch() without changes to their own code. The callback is invoked from the worker thread; callers are responsible for any required synchronisation.

The destructor blocks until all in-flight requests complete, so it is always safe to destroy the connection object.

Constructor & Destructor Documentation

~ThreadedConnection()

cpp_restapi::ThreadedConnection::~ThreadedConnection ( )

override

Member Function Documentation

BaseConnection()

cpp_restapi::BaseConnection::BaseConnection ( const std::string & address, const std::map< std::string, std::string > & headerEntries )

explicit

fetch() [1/4]

std::expected< std::string, HttpError > cpp_restapi::BaseConnection::fetch ( const std::string & request )

finalvirtual

Perform a single HTTP request.

Parameters

request

relative API path (e.g. "api/v1/disks")

Returns

response body on success, or an HttpError describing the failure

Returns std::unexpected(HttpError) when:

• The server returns a 4xx or 5xx status code
• A network-level failure occurs (statusCode == 0 in the error)

Reimplemented from cpp_restapi::BaseConnection.

fetch() [2/4]

CancellationToken cpp_restapi::BaseConnection::fetch ( const std::string & request, FetchCallback onSuccess, ErrorCallback onError = {} )

finalvirtual

Perform an HTTP GET request asynchronously.

Non-blocking. onSuccess is called with the full response when the request completes successfully; onError is called with an HttpError if the request fails. The callbacks may be invoked from a background thread (non-Qt backends) or from the Qt event-loop thread (Qt backend) — callers must handle thread-safety accordingly.

Parameters

request	relative API path (e.g. "users/octocat")
onSuccess	called with Response{body, headers, statusCode} on success
onError	called with an HttpError on failure (optional)

Returns

cancellation token; store it and set to true to suppress callbacks

Reimplemented from cpp_restapi::BaseConnection.

fetch() [3/4]

std::expected< std::string, HttpError > cpp_restapi::BaseConnection::fetch ( const std::string & request, IPaginationStrategy & strategy )

finalvirtual

Perform requests with automatic pagination.

Parameters

request	relative API path
strategy	pagination strategy defining how to discover next page and merge results

Returns

merged response body from all pages on success, or an HttpError on first failure

Reimplemented from cpp_restapi::BaseConnection.

fetch() [4/4]

CancellationToken cpp_restapi::BaseConnection::fetch ( const std::string & request, IPaginationStrategy & strategy, BodyCallback onSuccess, ErrorCallback onError = {} )

finalvirtual

Perform paginated requests asynchronously.

Non-blocking. Pages are fetched sequentially; once all pages have been collected the merged result is delivered via onSuccess. On any page failure onError is called and fetching stops.

Parameters

request	relative API path (e.g. "repos/owner/name/issues")
strategy	pagination strategy (next-page discovery and merge)
onSuccess	called with the merged body string on success
onError	called with an HttpError on failure (optional)

Returns

cancellation token

Reimplemented from cpp_restapi::BaseConnection.

fetchAsync()

void cpp_restapi::ThreadedConnection::fetchAsync ( const std::string & fullUrl, CancellationToken cancel, FetchCallback onSuccess, ErrorCallback onError )

overrideprotectedvirtual

Implements cpp_restapi::BaseConnection.

waitForPending()

void cpp_restapi::ThreadedConnection::waitForPending ( )

protected

Block until all in-flight async requests complete. Derived classes whose fetchPage() override is virtual should call this in their destructor to prevent pure-virtual calls.

---

The documentation for this class was generated from the following file:

• include/cpp_restapi/threaded_connection.hpp