From 4669ba9c6b07ea0f88f8e336740a29d106bc24cc Mon Sep 17 00:00:00 2001 From: wyc <1104749580@qq.com> Date: Thu, 25 Jun 2026 15:17:55 +0800 Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E8=BF=9B=E5=8D=8F=E7=A8=8B=E5=BE=AA?= =?UTF-8?q?=E7=8E=AF=E9=80=BB=E8=BE=912?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Core/socket/Socket_Coro.h | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) diff --git a/Core/socket/Socket_Coro.h b/Core/socket/Socket_Coro.h index c9ac8c1..3a7c6c1 100644 --- a/Core/socket/Socket_Coro.h +++ b/Core/socket/Socket_Coro.h @@ -45,6 +45,12 @@ public: send(data); co_return; } + + [[nodiscard]] concurrencpp::result close_coro() + { + close(); + co_return; + } }; class TCP_Server_Coro : public TCP_Server { @@ -86,6 +92,12 @@ public: { co_return accept(); } + + [[nodiscard]] concurrencpp::result close_coro() + { + close(); + co_return; + } }; class UDP_Client_Coro : public UDP_Client { @@ -111,10 +123,21 @@ public: send(data); co_return; } + + [[nodiscard]] concurrencpp::result close_coro() + { + close(); + co_return; + } }; class UDP_Server_Coro : public UDP_Server { public: + [[nodiscard]] concurrencpp::result bind_coro() + { + co_return bind(); + } + [[nodiscard]] concurrencpp::result tick_coro() { tick(); @@ -143,6 +166,12 @@ public: write_to_all_clients(msg); co_return; } + + [[nodiscard]] concurrencpp::result close_coro() + { + close(); + co_return; + } }; } // namespace Psc::asio_socket