Fix connected flag not being set to false. Closes #53

AxonIQ · Jun 8, 2023 · 8b4c6b3 · 8b4c6b3
1 parent d08c5e4
commit 8b4c6b3
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/inspector-axon/src/main/java/io/axoniq/inspector/client/RSocketInspectorClient.kt b/inspector-axon/src/main/java/io/axoniq/inspector/client/RSocketInspectorClient.kt
@@ -133,6 +133,9 @@ class RSocketInspectorClient(
         val client = TcpClient.create()
             .host(properties.host)
             .port(properties.port)
+            .doOnDisconnected {
+                connected = false
+            }
         return if (properties.secure) {
             return client.secure()
         } else client