From b048b02732cbfcfbb95bb8e16dec71aca0e977f4 Mon Sep 17 00:00:00 2001 From: Claudius 'keldu' Holeksa Date: Wed, 16 Oct 2024 18:51:50 +0200 Subject: Reworked abstraction for network --- modules/io/examples/echo_server.cpp | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'modules/io/examples/echo_server.cpp') diff --git a/modules/io/examples/echo_server.cpp b/modules/io/examples/echo_server.cpp index 4336048..0b0ea1b 100644 --- a/modules/io/examples/echo_server.cpp +++ b/modules/io/examples/echo_server.cpp @@ -4,7 +4,7 @@ #include "echo.hpp" -saw::error_or handle_echo_write(saw::io_stream& rmt_clt, saw::message& state, uint64_t tbw){ +saw::error_or handle_echo_write(saw::io_stream& rmt_clt, saw::message& state, uint64_t tbw){ auto eov = rmt_clt.write(&state.data[state.already_written], tbw); if(eov.is_error()){ return std::move(eov.get_error()); @@ -19,7 +19,7 @@ saw::error_or handle_echo_write(saw::io_stream& rmt_clt, saw::message& sta return saw::void_t{}; } -void handle_echo_message(saw::io_stream& rmt_clt, bool& keep_running, saw::message& state){ +void handle_echo_message(saw::io_stream& rmt_clt, bool& keep_running, saw::message& state){ rmt_clt.read_ready().then([&](){ for(;;){ uint64_t tbr = state.data.size() < state.already_read ? 0: state.data.size() - state.already_read; @@ -113,9 +113,9 @@ int main(){ }).detach(); auto& network = aio.io->get_network(); - saw::own addr = nullptr; - saw::own srv = nullptr; - saw::own remote_client = nullptr; + saw::own> addr = nullptr; + saw::own> srv = nullptr; + saw::own> remote_client = nullptr; saw::message msg_state; -- cgit v1.2.3