nerix
55 lines
1.3 KiB
C++
55 lines
1.3 KiB
C++
#pragma once
|
|
|
|
#include <QJsonObject>
|
|
#include <boost/asio.hpp>
|
|
#include <boost/asio/steady_timer.hpp>
|
|
#include <memory>
|
|
#include "common/QLogging.hpp"
|
|
#include "util/RapidjsonHelpers.hpp"
|
|
|
|
namespace chatterino {
|
|
|
|
class TwitchAccount;
|
|
struct ActionUser;
|
|
|
|
// Create timer using given ioService
|
|
template <typename Duration, typename Callback>
|
|
void runAfter(boost::asio::io_service &ioService, Duration duration,
|
|
Callback cb)
|
|
{
|
|
auto timer = std::make_shared<boost::asio::steady_timer>(ioService);
|
|
timer->expires_from_now(duration);
|
|
|
|
timer->async_wait([timer, cb](const boost::system::error_code &ec) {
|
|
if (ec)
|
|
{
|
|
qCDebug(chatterinoPubSub)
|
|
<< "Error in runAfter:" << ec.message().c_str();
|
|
return;
|
|
}
|
|
|
|
cb(timer);
|
|
});
|
|
}
|
|
|
|
// Use provided timer
|
|
template <typename Duration, typename Callback>
|
|
void runAfter(std::shared_ptr<boost::asio::steady_timer> timer,
|
|
Duration duration, Callback cb)
|
|
{
|
|
timer->expires_from_now(duration);
|
|
|
|
timer->async_wait([timer, cb](const boost::system::error_code &ec) {
|
|
if (ec)
|
|
{
|
|
qCDebug(chatterinoPubSub)
|
|
<< "Error in runAfter:" << ec.message().c_str();
|
|
return;
|
|
}
|
|
|
|
cb(timer);
|
|
});
|
|
}
|
|
|
|
} // namespace chatterino
|