Merge pull request #97 from boostorg/85-added-example-cpp20_streams-which-reproduces-an-assertion

85 added example cpp20 streams which reproduces an assertion

Author: mzimbres

CMakeLists.txt

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

README.md

@@ -678,6 +678,7 @@ Acknowledgement to people that helped shape Boost.Redis
 * Mohammad Nejati ([ashtum](https://github.com/ashtum)): For pointing out scenarios where calls to `async_exec` should fail when the connection is lost.
 * Klemens Morgenstern ([klemens-morgenstern](https://github.com/klemens-morgenstern)): For useful discussion about timeouts, cancellation, synchronous interfaces and general help with Asio.
 * Vinnie Falco ([vinniefalco](https://github.com/vinniefalco)): For general suggestions about how to improve the code and the documentation.
+* Bram Veldhoen ([bveldhoen](https://github.com/bveldhoen)): For contributing a Redis streams example.
 
 Also many thanks to all individuals that participated in the Boost
 review
@@ -702,6 +703,8 @@ https://lists.boost.org/Archives/boost/2023/01/253944.php.
 
 ### master (incorporates changes to conform the boost review and more)
 
+* Adds Redis stream example.
+
 * Renames the project to Boost.Redis and moves the code into namespace
   `boost::redis`.
 

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,9 +26,8 @@ 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";
    cfg.password = "aedis";
    cfg.addr.host = "db.occase.de";

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_protobuf.cpp

@@ -44,7 +44,7 @@ void boost_redis_from_bulk(person& u, std::string_view sv, boost::system::error_
 using tutorial::boost_redis_to_bulk;
 using tutorial::boost_redis_from_bulk;
 
-net::awaitable<void> co_main(config const& cfg)
+net::awaitable<void> co_main(config cfg)
 {
    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.