#include <cprjobhandler.hpp>
|
| CprJobHandler (boost::asio::io_context::executor_type executor) |
|
| ~CprJobHandler () override |
|
void | async (std::function< void()> func) override |
|
void | setTimeout (std::function< void()> func, int ms, std::optional< std::string > timerId=std::nullopt) override |
|
void | setInterval (std::function< void()> func, int ms, std::optional< std::string > timerId=std::nullopt) override |
|
void | cancel (std::string timerId) override |
| cancels all pending timers with timerId More...
|
|
void | submit (BaseJob job, std::function< void(Response)> callback) override |
| makes an async fetch. More...
|
|
void | stop () |
|
virtual | ~JobInterface ()=default |
|
◆ CprJobHandler()
Kazv::CprJobHandler::CprJobHandler |
( |
boost::asio::io_context::executor_type |
executor | ) |
|
◆ ~CprJobHandler()
Kazv::CprJobHandler::~CprJobHandler |
( |
| ) |
|
|
overridedefault |
◆ async()
void Kazv::CprJobHandler::async |
( |
std::function< void()> |
func | ) |
|
|
overridevirtual |
◆ cancel()
void Kazv::CprJobHandler::cancel |
( |
std::string |
timerId | ) |
|
|
overridevirtual |
◆ setInterval()
void Kazv::CprJobHandler::setInterval |
( |
std::function< void()> |
func, |
|
|
int |
ms, |
|
|
std::optional< std::string > |
timerId = std::nullopt |
|
) |
| |
|
overridevirtual |
◆ setTimeout()
void Kazv::CprJobHandler::setTimeout |
( |
std::function< void()> |
func, |
|
|
int |
ms, |
|
|
std::optional< std::string > |
timerId = std::nullopt |
|
) |
| |
|
overridevirtual |
◆ stop()
void Kazv::CprJobHandler::stop |
( |
| ) |
|
◆ submit()
void Kazv::CprJobHandler::submit |
( |
BaseJob |
job, |
|
|
std::function< void(Response)> |
callback |
|
) |
| |
|
overridevirtual |
makes an async fetch.
callback should not block the current thread. if job has a queueId
, it must be queued and executed only after every job before it in the queue queueId
returned. if job has a queuePolicy
of CancelFutureIfFailed, the failure of this job must remove every other job after it in the queue queueId
.
Implements Kazv::JobInterface.
The documentation for this struct was generated from the following files: