fix reset

Author: poor-circle

include/ylt/coro_io/socket_wrapper.hpp

@@ -22,7 +22,7 @@
 namespace coro_io {
 struct socket_wrapper_t {
   // construct by listen tcp
-  socket_wrapper_t(){};
+  socket_wrapper_t() {};
   socket_wrapper_t(coro_io::ExecutorWrapper<> *executor)
       : socket_(std::make_unique<asio::ip::tcp::socket>(
             executor->get_asio_executor())),
@@ -76,12 +76,6 @@ struct socket_wrapper_t {
   }
 #endif
 
-  void reset() {
-    if (socket_) {
-      *socket_ = asio::ip::tcp::socket(executor_->get_asio_executor());
-    }
-  }
-
  private:
   std::unique_ptr<asio::ip::tcp::socket> socket_;
   coro_io::ExecutorWrapper<> *executor_;
@@ -171,8 +165,8 @@ struct socket_wrapper_t {
     ssl_stream_ = std::make_unique<asio::ssl::stream<asio::ip::tcp::socket &>>(
         *socket_, ssl_ctx);
   }
-  std::unique_ptr<asio::ssl::stream<asio::ip::tcp::socket &>>
-      &ssl_stream() noexcept {
+  std::unique_ptr<asio::ssl::stream<asio::ip::tcp::socket &>> &
+  ssl_stream() noexcept {
     return ssl_stream_;
   }
   using tcp_socket_with_ssl_t = asio::ssl::stream<asio::ip::tcp::socket &>;

include/ylt/coro_rpc/impl/coro_rpc_client.hpp

@@ -530,7 +530,11 @@ class coro_rpc_client {
 
   async_simple::coro::Lazy<void> reset() {
     co_await close_socket(control_);
-    control_->socket_wrapper_.reset();
+    std::visit(
+        [this](auto &socket_config) {
+          return init_socket_wrapper(socket_config);
+        },
+        config_.socket_config);
     control_->is_timeout_ = false;
     control_->has_closed_ = false;
     co_return;