threaded_connection.hpp

Go to the documentation of this file.

#ifndef THREADED_CONNECTION_HPP_INCLUDED
#define THREADED_CONNECTION_HPP_INCLUDED
 
#include <condition_variable>
#include <mutex>
 
#include "base_connection.hpp"
#include "cpp_restapi_export.h"
 
 
namespace cpp_restapi
{
    class CPP_RESTAPI_EXPORT ThreadedConnection : public BaseConnection
    {
    public:
        using BaseConnection::BaseConnection;
        using BaseConnection::fetch;
 
        ~ThreadedConnection() override;
 
    protected:
        void fetchAsync(const std::string& fullUrl,
                        CancellationToken cancel,
                        FetchCallback onSuccess,
                        ErrorCallback onError) override;
 
        void waitForPending();
 
    private:
        std::mutex m_mutex;
        std::condition_variable m_cv;
        unsigned m_activeCount = 0;
    };
}
 
#endif