boost/redis
2
0
Fork 0
mirror of https://github.com/boostorg/redis.git synced 2026-01-28 19:32:15 +00:00
Code Issues Projects Releases Wiki Activity

Progresses with the subscriber.

Browse Source
This commit is contained in:
Marcelo Zimbres
2023-03-22 02:16:33 +01:00
parent e7ff1cedf3
commit 7a08588808
17 changed files with 169 additions and 79 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
examples/cpp17_intro_sync.cpp
View File

@@ -8,6 +8,7 @@
#include <boost/redis/request.hpp>
#include <boost/redis/check_health.hpp>
#include <boost/redis/run.hpp>
#include <boost/redis/logger.hpp>
#include <boost/asio/deferred.hpp>
#include <boost/asio/use_future.hpp>
#include <tuple>
@@ -27,6 +28,7 @@ using boost::redis::response;
using boost::redis::ignore_t;
using boost::redis::async_run;
using boost::redis::address;
using boost::redis::logger;
using boost::redis::async_check_health;
using namespace std::chrono_literals;
@@ -56,7 +58,7 @@ auto main(int argc, char * argv[]) -> int
// Starts a thread that will can io_context::run on which the
// connection will run.
std::thread t{[&ioc, conn, addr]() {
async_run(*conn, addr, 10s, 10s, [conn](auto){
async_run(*conn, addr, 10s, 10s, logger{}, [conn](auto){
conn->cancel();
});