Cleaned up a bit

Removed unused stuff
Using request and response as shared_ptrs.
Removed (unnecessary?) calls to net::post.

Author: bram

CMakeLists.txt

@@ -95,7 +95,6 @@ endif()
 add_executable(cpp20_streams examples/cpp20_streams.cpp)
 target_link_libraries(cpp20_streams common)
 target_compile_features(cpp20_streams PUBLIC cxx_std_20)
-add_test(cpp20_streams cpp20_streams)
 if (MSVC)
     target_compile_options(cpp20_streams PRIVATE /bigobj)
     target_compile_definitions(cpp20_streams PRIVATE _WIN32_WINNT=0x0601)

examples/cpp20_chat_room.cpp

@@ -72,7 +72,7 @@ auto publisher(std::shared_ptr<stream_descriptor> in, std::shared_ptr<connection
 }
 
 // Called from the main function (see main.cpp)
-auto co_main(config const& cfg) -> net::awaitable<void>
+auto co_main(config cfg) -> net::awaitable<void>
 {
    auto ex = co_await net::this_coro::executor;
    auto conn = std::make_shared<connection>(ex);

examples/cpp20_containers.cpp

@@ -89,7 +89,7 @@ auto transaction(std::shared_ptr<connection> conn) -> net::awaitable<void>
 }
 
 // Called from the main function (see main.cpp)
-net::awaitable<void> co_main(config const& cfg)
+net::awaitable<void> co_main(config cfg)
 {
    auto conn = std::make_shared<connection>(co_await net::this_coro::executor);
    conn->async_run(cfg, {}, net::consign(net::detached, conn));

examples/cpp20_echo_server.cpp

@@ -55,7 +55,7 @@ auto listener(std::shared_ptr<connection> conn) -> net::awaitable<void>
 }
 
 // Called from the main function (see main.cpp)
-auto co_main(config const& cfg) -> net::awaitable<void>
+auto co_main(config cfg) -> net::awaitable<void>
 {
    auto ex = co_await net::this_coro::executor;
    auto conn = std::make_shared<connection>(ex);

examples/cpp20_intro.cpp

@@ -21,7 +21,7 @@ using boost::redis::logger;
 using connection = net::deferred_t::as_default_on_t<boost::redis::connection>;
 
 // Called from the main function (see main.cpp)
-auto co_main(config const& cfg) -> net::awaitable<void>
+auto co_main(config cfg) -> net::awaitable<void>
 {
    auto conn = std::make_shared<connection>(co_await net::this_coro::executor);
    conn->async_run(cfg, {}, net::consign(net::detached, conn));

examples/cpp20_intro_tls.cpp

@@ -26,7 +26,7 @@ auto verify_certificate(bool, net::ssl::verify_context&) -> bool
    return true;
 }
 
-auto co_main(config const&) -> net::awaitable<void>
+auto co_main(config cfg) -> net::awaitable<void>
 {
    config cfg;
    cfg.username = "aedis";

examples/cpp20_json.cpp

@@ -45,7 +45,7 @@ void boost_redis_to_bulk(std::string& to, user const& u)
 void boost_redis_from_bulk(user& u, std::string_view sv, boost::system::error_code& ec)
    { boost::redis::json::from_bulk(u, sv, ec); }
 
-net::awaitable<void> co_main(config const& cfg)
+auto co_main(config cfg) -> net::awaitable<void>
 {
    auto ex = co_await net::this_coro::executor;
    auto conn = std::make_shared<connection>(ex);

examples/cpp20_resolve_with_sentinel.cpp

@@ -55,7 +55,7 @@ auto resolve_master_address(std::vector<address> const& addresses) -> net::await
    co_return address{};
 }
 
-auto co_main(config const& cfg) -> net::awaitable<void>
+auto co_main(config cfg) -> net::awaitable<void>
 {
    // A list of sentinel addresses from which only one is responsive.
    // This simulates sentinels that are down.

examples/cpp20_streams.cpp

@@ -15,6 +15,11 @@
 
 #if defined(BOOST_ASIO_HAS_CO_AWAIT)
 
+#include <memory>
+#include <string>
+#include <thread>
+#include <vector>
+
 namespace net = boost::asio;
 using boost::redis::config;
 using boost::redis::generic_response;
@@ -72,7 +77,6 @@ auto stream_reader(std::shared_ptr<connection> conn) -> net::awaitable<void>
         req.clear();
         resp.value().clear();
     }
-
 }
 
 // Run this in another terminal:
@@ -82,6 +86,9 @@ auto co_main(config cfg) -> net::awaitable<void>
    auto ex = co_await net::this_coro::executor;
    auto conn = std::make_shared<connection>(ex);
    net::co_spawn(ex, stream_reader(conn), net::detached);
+
+   // Disable health checks.
+   cfg.health_check_interval = std::chrono::seconds{0};
    conn->async_run(cfg, {}, net::consign(net::detached, conn));
 
    signal_set sig_set(ex, SIGINT, SIGTERM);

examples/cpp20_subscriber.cpp

@@ -72,7 +72,7 @@ receiver(std::shared_ptr<connection> conn) -> net::awaitable<void>
    }
 }
 
-auto co_main(config const& cfg) -> net::awaitable<void>
+auto co_main(config cfg) -> net::awaitable<void>
 {
    auto ex = co_await net::this_coro::executor;
    auto conn = std::make_shared<connection>(ex);