diff --git a/src/Pulsar.Client/Internal/ClientCnx.fs b/src/Pulsar.Client/Internal/ClientCnx.fs
index b152f4e5..714230b2 100644
--- a/src/Pulsar.Client/Internal/ClientCnx.fs
+++ b/src/Pulsar.Client/Internal/ClientCnx.fs
@@ -840,8 +840,7 @@ and internal ClientCnx (config: PulsarClientConfiguration,
                     if initialConnectionTsc.TrySetException(ConnectException("Unable to initiate connection")) then
                         Log.Logger.LogWarning("{0} New connection was aborted", prefix)
                     Log.Logger.LogWarning(ex, "{0} Socket was disconnected exceptionally while reading", prefix)
-                    post operationsMb ChannelInactive
-
+                post operationsMb ChannelInactive
             Log.Logger.LogDebug("{0} readSocket stopped", prefix)
         } :> Task