summaryrefslogtreecommitdiff
path: root/modules/io_codec/examples
diff options
context:
space:
mode:
authorClaudius 'keldu' Holeksa <mail@keldu.de>2024-08-08 17:24:24 +0200
committerClaudius 'keldu' Holeksa <mail@keldu.de>2024-08-08 17:24:24 +0200
commit139b727e1b60bb309d40260b9577dcec7ce3bf53 (patch)
treea0adc6ac4cbbb5638c1da98472176d7b0a3c97c6 /modules/io_codec/examples
parent8fd1eaa255ff71e325eded82740e0942494f7264 (diff)
wip debug
Diffstat (limited to 'modules/io_codec/examples')
-rw-r--r--modules/io_codec/examples/peer_echo_server.cpp5
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();