Merge pull request #248 from boostorg/refactoring_clean_code

Sans-io multiplexing

Author: mzimbres

include/boost/redis/adapter/any_adapter.hpp

@@ -18,14 +18,6 @@
 
 namespace boost::redis {
 
-namespace detail { 
-
-// Forward decl
-template <class Executor>
-class basic_connection;
-
-}
-
 /** @brief A type-erased reference to a response.
  *  @ingroup high-level-api
  *
@@ -39,9 +31,9 @@ class basic_connection;
  *      co_await conn.async_exec(req, any_response(resp));
  *  ```
  */
-class any_adapter
-{
-    using fn_type = std::function<void(std::size_t, resp3::basic_node<std::string_view> const&, system::error_code&)>;
+class any_adapter {
+public:
+    using fn_type = std::function<void(std::size_t, resp3::node_view const&, system::error_code&)>;
 
     struct impl_t {
         fn_type adapt_fn;
@@ -60,7 +52,6 @@ class any_adapter
     template <class Executor>
     friend class basic_connection;
 
-public:
     /**
      * @brief Constructor.
      * 

include/boost/redis/config.hpp

@@ -10,6 +10,7 @@
 #include <string>
 #include <chrono>
 #include <optional>
+#include <limits>
 
 namespace boost::redis
 {
@@ -78,6 +79,13 @@ struct config {
     *  To disable reconnection pass zero as duration.
     */
    std::chrono::steady_clock::duration reconnect_wait_interval = std::chrono::seconds{1};
+
+   /** @brief Maximum size of a socket read.
+    *  
+    *  Sets a limit on how much data is allowed to be read into the
+    *  read buffer. It can be used to prevent DDOS.
+    */
+   std::size_t max_read_size = (std::numeric_limits<std::size_t>::max)();
 };
 
 } // boost::redis