diff options
Diffstat (limited to 'modules/io_codec/examples')
| -rw-r--r-- | modules/io_codec/examples/echo.hpp | 2 | ||||
| -rw-r--r-- | modules/io_codec/examples/peer_echo_client.cpp | 23 |
2 files changed, 9 insertions, 16 deletions
diff --git a/modules/io_codec/examples/echo.hpp b/modules/io_codec/examples/echo.hpp index 84b9b31..04819b0 100644 --- a/modules/io_codec/examples/echo.hpp +++ b/modules/io_codec/examples/echo.hpp @@ -13,6 +13,6 @@ using Echo = String; } namespace saw { -constexpr std::string echo_address = "::1"; +constexpr std::string echo_address = "127.0.0.1"; constexpr uint16_t echo_port = 4322; } diff --git a/modules/io_codec/examples/peer_echo_client.cpp b/modules/io_codec/examples/peer_echo_client.cpp index d2c4351..90f9627 100644 --- a/modules/io_codec/examples/peer_echo_client.cpp +++ b/modules/io_codec/examples/peer_echo_client.cpp @@ -35,16 +35,8 @@ int main(){ auto& addr = eo_addr.get_value(); data<sch::Echo> nat_echo{"hello"}; - data<sch::Echo, encode::KelSimple> simple_echo; codec<sch::Echo, encode::KelSimple> simple_codec; - { - auto eov = simple_codec.encode(nat_echo, simple_echo); - if(eov.is_error()){ - return -1; - } - } - network.connect(*addr).then([&](saw::own<saw::io_stream> client){ if(!client){ return; @@ -54,6 +46,14 @@ int main(){ auto echo_peer_stream_p = saw::new_streaming_io_peer<sch::Echo, sch::Echo, trans::FixedLength<8u>, encode::KelSimple, ring_buffer>(std::move(echo_stream)); std::cout<<"Connected"<<std::endl; + + data<sch::Echo, encode::KelSimple> simple_echo; + { + auto eov = simple_codec.encode(nat_echo, simple_echo); + if(eov.is_error()){ + return ; + } + } { auto eo_send = echo_peer_stream_p.first->send(std::move(simple_echo)); if(eo_send.is_error()){ @@ -61,13 +61,6 @@ int main(){ } } std::cout<<"Sent data"<<std::endl; - { - simple_echo = {}; - auto eov = simple_codec.encode(nat_echo, simple_echo); - if(eov.is_error()){ - return ; - } - } data<sch::Echo> nat_resp; echo_peer_stream_p.second.then([&](auto simp_resp){ |