#ifndef AsyncRequest_h
#define AsyncRequest_h
#include <functional>
#include <wtf/PassRefPtr.h>
#include <wtf/RefCounted.h>
namespace WebKit {
class AsyncRequest : public RefCounted<AsyncRequest> {
public:
virtual ~AsyncRequest();
uint64_t requestID() { return m_requestID; }
void setAbortHandler(std::function<void ()>);
void requestAborted();
template<typename... Arguments> void completeRequest(Arguments&&... arguments);
protected:
explicit AsyncRequest(std::function<void ()> abortHandler);
virtual void clearCompletionHandler() = 0;
std::function<void ()> m_abortHandler;
private:
uint64_t m_requestID;
};
template <typename... Arguments>
class AsyncRequestImpl final : public AsyncRequest {
public:
static PassRefPtr<AsyncRequest> create(std::function<void (Arguments...)> completionHandler)
{
return adoptRef(new AsyncRequestImpl<Arguments...>(WTF::move(completionHandler), nullptr));
}
static PassRefPtr<AsyncRequest> create(std::function<void (Arguments...)> completionHandler, std::function<void ()> abortHandler)
{
return adoptRef(new AsyncRequestImpl<Arguments...>(WTF::move(completionHandler), WTF::move(abortHandler)));
}
virtual ~AsyncRequestImpl()
{
ASSERT(!m_completionHandler);
}
void completeRequest(Arguments&&... arguments)
{
m_completionHandler(std::forward<Arguments>(arguments)...);
m_completionHandler = nullptr;
}
private:
AsyncRequestImpl(std::function<void (Arguments...)> completionHandler, std::function<void ()> abortHandler)
: AsyncRequest(WTF::move(abortHandler))
, m_completionHandler(WTF::move(completionHandler))
{
ASSERT(m_completionHandler);
}
virtual void clearCompletionHandler() override
{
m_completionHandler = nullptr;
}
std::function<void (Arguments...)> m_completionHandler;
};
template<typename... Arguments> void AsyncRequest::completeRequest(Arguments&&... arguments)
{
AsyncRequestImpl<Arguments...>* request = static_cast<AsyncRequestImpl<Arguments...>*>(this);
request->completeRequest(std::forward<Arguments>(arguments)...);
m_abortHandler = nullptr;
}
}
#endif // AsyncRequest_h