diff options
Diffstat (limited to 'modules/io_codec/examples')
| -rw-r--r-- | modules/io_codec/examples/peer_echo_server.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/modules/io_codec/examples/peer_echo_server.cpp b/modules/io_codec/examples/peer_echo_server.cpp index a949ff5..279db92 100644 --- a/modules/io_codec/examples/peer_echo_server.cpp +++ b/modules/io_codec/examples/peer_echo_server.cpp @@ -58,16 +58,18 @@ int main(){ auto echo_stream = saw::heap<saw::async_io_stream>(std::move(client)); 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<<"Got client"<<std::endl; - echo_peer_stream_p.second.then([&](auto simp_resp) -> error_or<void>{ + echo_peer_stream_p.second.then([&](auto simp_resp) -> error_or<void> { + std::cout<<"Request\n"; data<sch::Echo> nat_resp; { auto eov = simple_codec.decode(simp_resp, nat_resp); if(eov.is_error()){ + std::cerr<<"Failed to decode"<<std::endl; return eov; } } - std::cout<<"Request:\n"; for(uint64_t i = 0u; i < nat_resp.size(); ++i){ std::cout<<nat_resp.at(i); } |