(iggy) branch master updated: fix(sdk): prevent client from getting stuck after disconnect (#2610)

[piotr]

This is an automated email from the ASF dual-hosted git repository.

piotr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git


The following commit(s) were added to refs/heads/master by this push:
     new 73de5c1c1 fix(sdk): prevent client from getting stuck after disconnect 
(#2610)
73de5c1c1 is described below

commit 73de5c1c153290c1d8e4327b6cb51a633104b49c
Author: Hubert Gruszecki <h.grusze...@gmail.com>
AuthorDate: Mon Jan 26 14:19:20 2026 +0100

    fix(sdk): prevent client from getting stuck after disconnect (#2610)
    
    NotConnected error was not triggering reconnection logic,
    causing clients to remain permanently disconnected
    when heartbeat or poll operations failed after connection loss.
---
 Cargo.lock                     | 2 +-
 DEPENDENCIES.md                | 2 +-
 core/sdk/Cargo.toml            | 2 +-
 core/sdk/src/tcp/tcp_client.rs | 2 ++
 4 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index e25a50414..26de47328 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -4419,7 +4419,7 @@ dependencies = [
 
 [[package]]
 name = "iggy"
-version = "0.8.1-edge.4"
+version = "0.8.1-edge.5"
 dependencies = [
  "async-broadcast",
  "async-dropper",
diff --git a/DEPENDENCIES.md b/DEPENDENCIES.md
index 4edd99ca1..3150cc05e 100644
--- a/DEPENDENCIES.md
+++ b/DEPENDENCIES.md
@@ -386,7 +386,7 @@ icu_provider: 2.1.1, "Unicode-3.0",
 ident_case: 1.0.1, "Apache-2.0 OR MIT",
 idna: 1.1.0, "Apache-2.0 OR MIT",
 idna_adapter: 1.2.1, "Apache-2.0 OR MIT",
-iggy: 0.8.1-edge.4, "Apache-2.0",
+iggy: 0.8.1-edge.5, "Apache-2.0",
 iggy-bench: 0.3.1-edge.1, "Apache-2.0",
 iggy-bench-dashboard-server: 0.5.1-edge.1, "Apache-2.0",
 iggy-cli: 0.10.1-edge.1, "Apache-2.0",
diff --git a/core/sdk/Cargo.toml b/core/sdk/Cargo.toml
index 1ac7bcdf2..c83cfc06b 100644
--- a/core/sdk/Cargo.toml
+++ b/core/sdk/Cargo.toml
@@ -17,7 +17,7 @@
 
 [package]
 name = "iggy"
-version = "0.8.1-edge.4"
+version = "0.8.1-edge.5"
 description = "Iggy is the persistent message streaming platform written in 
Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing 
millions of messages per second."
 edition = "2024"
 license = "Apache-2.0"
diff --git a/core/sdk/src/tcp/tcp_client.rs b/core/sdk/src/tcp/tcp_client.rs
index 571f1b7cb..0ff62179c 100644
--- a/core/sdk/src/tcp/tcp_client.rs
+++ b/core/sdk/src/tcp/tcp_client.rs
@@ -120,6 +120,8 @@ impl BinaryTransport for TcpClient {
                 | IggyError::EmptyResponse
                 | IggyError::Unauthenticated
                 | IggyError::StaleClient
+                | IggyError::NotConnected
+                | IggyError::CannotEstablishConnection
         ) {
             return Err(error);
         }