Reduce changes

Author: BewareMyPower

lib/HandlerBase.cc

@@ -89,23 +89,23 @@ void HandlerBase::grabCnx() {
         return;
     }
     auto self = shared_from_this();
-    client->getConnection(topic(), connectionKeySuffix_)
-        .addListener([this, self](Result result, const ClientConnectionPtr& cnx) {
-            if (result == ResultOk) {
-                LOG_DEBUG(getName() << "Connected to broker: " << cnx->cnxString());
-                connectionOpened(cnx).addListener([this, self](Result result, bool) {
-                    // Do not use bool, only Result.
-                    reconnectionPending_ = false;
-                    if (isResultRetryable(result)) {
-                        scheduleReconnection();
-                    }
-                });
-            } else {
-                connectionFailed(result);
+    auto cnxFuture = client->getConnection(topic(), connectionKeySuffix_);
+    cnxFuture.addListener([this, self](Result result, const ClientConnectionPtr& cnx) {
+        if (result == ResultOk) {
+            LOG_DEBUG(getName() << "Connected to broker: " << cnx->cnxString());
+            connectionOpened(cnx).addListener([this, self](Result result, bool) {
+                // Do not use bool, only Result.
                 reconnectionPending_ = false;
-                scheduleReconnection();
-            }
-        });
+                if (isResultRetryable(result)) {
+                    scheduleReconnection();
+                }
+            });
+        } else {
+            connectionFailed(result);
+            reconnectionPending_ = false;
+            scheduleReconnection();
+        }
+    });
 }
 
 void HandlerBase::handleDisconnection(Result result, const ClientConnectionPtr& cnx) {