改进协程循环逻辑2

This commit is contained in:
2026-06-25 15:17:55 +08:00
parent 818b400318
commit 4669ba9c6b
+29
View File
@@ -45,6 +45,12 @@ public:
send(data);
co_return;
}
[[nodiscard]] concurrencpp::result<void> close_coro()
{
close();
co_return;
}
};
class TCP_Server_Coro : public TCP_Server {
@@ -86,6 +92,12 @@ public:
{
co_return accept();
}
[[nodiscard]] concurrencpp::result<void> close_coro()
{
close();
co_return;
}
};
class UDP_Client_Coro : public UDP_Client {
@@ -111,10 +123,21 @@ public:
send(data);
co_return;
}
[[nodiscard]] concurrencpp::result<void> close_coro()
{
close();
co_return;
}
};
class UDP_Server_Coro : public UDP_Server {
public:
[[nodiscard]] concurrencpp::result<bool> bind_coro()
{
co_return bind();
}
[[nodiscard]] concurrencpp::result<void> tick_coro()
{
tick();
@@ -143,6 +166,12 @@ public:
write_to_all_clients(msg);
co_return;
}
[[nodiscard]] concurrencpp::result<void> close_coro()
{
close();
co_return;
}
};
} // namespace Psc::asio_socket