diff options
author | Claudius 'keldu' Holeksa <mail@keldu.de> | 2024-08-08 17:24:24 +0200 |
---|---|---|
committer | Claudius 'keldu' Holeksa <mail@keldu.de> | 2024-08-08 17:24:24 +0200 |
commit | 139b727e1b60bb309d40260b9577dcec7ce3bf53 (patch) | |
tree | a0adc6ac4cbbb5638c1da98472176d7b0a3c97c6 /modules/io_codec/examples/peer_echo_server.cpp | |
parent | 8fd1eaa255ff71e325eded82740e0942494f7264 (diff) |
wip debug
Diffstat (limited to 'modules/io_codec/examples/peer_echo_server.cpp')
-rw-r--r-- | modules/io_codec/examples/peer_echo_server.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/modules/io_codec/examples/peer_echo_server.cpp b/modules/io_codec/examples/peer_echo_server.cpp index 279db92..02a7272 100644 --- a/modules/io_codec/examples/peer_echo_server.cpp +++ b/modules/io_codec/examples/peer_echo_server.cpp @@ -84,8 +84,9 @@ int main(){ } return make_void(); }).detach(); - - echo_peer_stream_p.first->on_read_disconnected().attach(std::move(echo_peer_stream_p.first)).then([]() -> error_or<void>{ + + auto peer_str = echo_peer_stream_p.first.get(); + peer_str->on_read_disconnected().attach(std::move(echo_peer_stream_p.first)).then([]() -> error_or<void>{ return make_error<err::critical>("Destroy pipeline on purpose :>"); }).detach(); }).detach(); |