7#include <boost/redis/connection.hpp>
8#include <boost/redis/logger.hpp>
10#include <boost/asio/awaitable.hpp>
11#include <boost/asio/co_spawn.hpp>
12#include <boost/asio/consign.hpp>
13#include <boost/asio/detached.hpp>
14#include <boost/asio/redirect_error.hpp>
15#include <boost/asio/signal_set.hpp>
16#include <boost/asio/use_awaitable.hpp>
20#if defined(BOOST_ASIO_HAS_CO_AWAIT)
22namespace asio = boost::asio;
23using namespace std::chrono_literals;
26using boost::redis::consume_one;
31using boost::system::error_code;
33using asio::signal_set;
52auto receiver(std::shared_ptr<connection> conn) -> asio::awaitable<void>
55 req.push(
"SUBSCRIBE",
"channel");
58 conn->set_receive_response(resp);
61 while (conn->will_reconnect()) {
63 co_await conn->async_exec(req, ignore);
66 for (error_code ec;;) {
69 if (ec == error::sync_receive_push_failed) {
71 co_await conn->async_receive(asio::redirect_error(asio::use_awaitable, ec));
77 std::cout << resp.value().at(1).value <<
" " << resp.value().at(2).value <<
" "
78 << resp.value().at(3).value << std::endl;
85auto co_main(config cfg) -> asio::awaitable<void>
87 auto ex =
co_await asio::this_coro::executor;
88 auto conn = std::make_shared<connection>(ex);
89 asio::co_spawn(ex, receiver(conn), asio::detached);
90 conn->async_run(cfg, asio::consign(asio::detached, conn));
92 signal_set sig_set(ex, SIGINT, SIGTERM);
93 co_await sig_set.async_wait();
A basic_connection that type erases the executor.
ignore_t ignore
Global ignore object.
adapter::result< std::vector< resp3::node > > generic_response
A generic response to a request.
Configure parameters used by the connection classes.
Defines logging configuration.