diff --git a/module/Local_Server/Data_Feed/Data_Feed.h b/module/Local_Server/Data_Feed/Data_Feed.h index eb5d422..aedf2cc 100644 --- a/module/Local_Server/Data_Feed/Data_Feed.h +++ b/module/Local_Server/Data_Feed/Data_Feed.h @@ -111,7 +111,7 @@ public: std::uint16_t port{}; size_t connect_user_buffer_size{}; size_t connect_system_buffer_size{}; - Psc::asio_socket::TCP_Server svr; + Psc::asio_socket::TCP_Server_Coro svr; Psc::JSON get_custom_state_json() override { auto& state = svr.state; Psc::JSON ret = Psc::JSON::object(); @@ -193,7 +193,7 @@ public: return VAR_JSON_1(state); } std::uint16_t port{}; - Psc::asio_socket::TCP_Client cli; + Psc::asio_socket::TCP_Client_Coro cli; ~Data_Feed_TCP_Client() override = default; void _close() override { cli.close(); } bool _open() override { @@ -255,7 +255,7 @@ public: void _close() override { svr.close(); } bool _open() override; std::uint16_t port{}; - Psc::asio_socket::UDP_Server svr; + Psc::asio_socket::UDP_Server_Coro svr; }; @@ -270,7 +270,7 @@ public: void handle_in_loop() override { ucoro::sync_await(cli.tick_coro()); } - Psc::asio_socket::UDP_Client cli; + Psc::asio_socket::UDP_Client_Coro cli; std::string url; std::uint16_t port{}; void from_json(const Psc::JSON* that_json) override { diff --git a/module/Local_Server/Data_Source/Data_Source.h b/module/Local_Server/Data_Source/Data_Source.h index ee5331a..eb2bcc4 100644 --- a/module/Local_Server/Data_Source/Data_Source.h +++ b/module/Local_Server/Data_Source/Data_Source.h @@ -230,7 +230,7 @@ struct TCP_Client_Data_Source : Data_Source { auto& state = cli.state; return VAR_JSON_1(state); } - Psc::asio_socket::TCP_Client cli; + Psc::asio_socket::TCP_Client_Coro cli; std::string ip; std::uint16_t port{};