.

1 files changed, 3 insertions, 0 deletions

diff --git a/core/src/service/tcp_network/long_connection.rs b/core/src/service/tcp_network/long_connection.rs
index a08fc6d..1bac6a2 100644
--- a/core/src/service/tcp_network/long_connection.rs
+++ b/core/src/service/tcp_network/long_connection.rs
@@ -211,6 +211,9 @@ impl PadClientNetwork {
                 }
                 Err(err) => {
                     error!("[TCP Client] [Runtime] Reader encountered an error: {}", err);
+                    entry_mutex!(self.runtime, |guard| {
+                        guard.send(ControlMessage::End, 0, TCPConnection);
+                    });
                     break;
                 }
             }