summaryrefslogtreecommitdiff
path: root/modules/io_codec/examples/peer_echo_server.cpp
diff options
context:
space:
mode:
authorClaudius 'keldu' Holeksa <mail@keldu.de>2024-08-09 18:26:48 +0200
committerClaudius 'keldu' Holeksa <mail@keldu.de>2024-08-09 18:26:48 +0200
commit17431a0c95558ed61f092fa019231df89677ca0f (patch)
treeff4934738e7a4975af552f1da4ee7343c9ec09ed /modules/io_codec/examples/peer_echo_server.cpp
parenta64b8346f39a34ef811b679bbed8131e2098e546 (diff)
wip
Diffstat (limited to 'modules/io_codec/examples/peer_echo_server.cpp')
-rw-r--r--modules/io_codec/examples/peer_echo_server.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/modules/io_codec/examples/peer_echo_server.cpp b/modules/io_codec/examples/peer_echo_server.cpp
index 87bf721..d579622 100644
--- a/modules/io_codec/examples/peer_echo_server.cpp
+++ b/modules/io_codec/examples/peer_echo_server.cpp
@@ -86,7 +86,8 @@ int main(){
return make_void();
}).detach();
- peer_str->on_read_disconnected().attach(std::move(echo_peer_stream_p.first)).then([]() -> error_or<void>{
+ peer_str->on_disconnected().attach(std::move(echo_peer_stream_p.first)).then([]() -> error_or<void>{
+ std::cout<<"Disconnected client"<<std::endl;
return make_error<err::critical>("Destroy pipeline on purpose :>");
}).detach();
}).detach();