diff options
author | Claudius 'keldu' Holeksa <mail@keldu.de> | 2024-10-16 18:51:50 +0200 |
---|---|---|
committer | Claudius 'keldu' Holeksa <mail@keldu.de> | 2024-10-16 18:51:50 +0200 |
commit | b048b02732cbfcfbb95bb8e16dec71aca0e977f4 (patch) | |
tree | 8f948159473f40ca42c73d75e61d8d03c3b38f24 /modules/io/examples/echo_server.cpp | |
parent | b10d0b0e1a30eb02777f5a02b81bf45e09749edb (diff) |
Reworked abstraction for network
Diffstat (limited to 'modules/io/examples/echo_server.cpp')
-rw-r--r-- | modules/io/examples/echo_server.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
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<void> handle_echo_write(saw::io_stream& rmt_clt, saw::message& state, uint64_t tbw){ +saw::error_or<void> handle_echo_write(saw::io_stream<saw::net::Os>& 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<void> 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<saw::net::Os>& 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<saw::network_address> addr = nullptr; - saw::own<saw::server> srv = nullptr; - saw::own<saw::io_stream> remote_client = nullptr; + saw::own<saw::network_address<saw::net::Os>> addr = nullptr; + saw::own<saw::server<saw::net::Os>> srv = nullptr; + saw::own<saw::io_stream<saw::net::Os>> remote_client = nullptr; saw::message msg_state; |