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

Uses asio::deferred_t as default completion type.

Browse Source
This commit is contained in:
Marcelo Zimbres
2024-12-23 22:05:21 +01:00
parent 6cdbd64eb8
commit 3a74575ada
10 changed files with 35 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
example/cpp20_subscriber.cpp
View File

@@ -8,7 +8,6 @@
#include <boost/redis/logger.hpp>
#include <boost/asio/awaitable.hpp>
#include <boost/asio/use_awaitable.hpp>
#include <boost/asio/deferred.hpp>
#include <boost/asio/co_spawn.hpp>
#include <boost/asio/detached.hpp>
#include <boost/asio/consign.hpp>
@@ -29,7 +28,7 @@ using boost::redis::ignore;
using boost::redis::error;
using boost::system::error_code;
using boost::redis::connection;
using signal_set = asio::deferred_t::as_default_on_t<asio::signal_set>;
using asio::signal_set;
/* This example will subscribe and read pushes indefinitely.
*
@@ -61,7 +60,7 @@ receiver(std::shared_ptr<connection> conn) -> asio::awaitable<void>
while (conn->will_reconnect()) {
// Reconnect to the channels.
co_await conn->async_exec(req, ignore, asio::deferred);
co_await conn->async_exec(req, ignore);
// Loop reading Redis pushs messages.
for (error_code ec;;) {