prettier formatting

SOHU-Co · Jan 30, 2018 · bb7fde9 · bb7fde9
1 parent 11230a0
commit bb7fde9
Showing 1 changed file with 30 additions and 14 deletions.
diff --git a/lib/kafkaClient.js b/lib/kafkaClient.js
@@ -333,7 +333,7 @@ KafkaClient.prototype.updateMetadatas = function (metadatas, replaceTopicMetadat
   logger.debug('updating metadatas');
   this.setBrokerMetadata(metadatas[0]);
   if (replaceTopicMetadata) {
-  this.topicMetadata = metadatas[1].metadata;
+    this.topicMetadata = metadatas[1].metadata;
   } else {
     _.extend(this.topicMetadata, metadatas[1].metadata);
   }
@@ -423,7 +423,9 @@ KafkaClient.prototype.getListGroups = function (callback) {
     return callback(new Error('Client is not ready (getListGroups)'));
   }
   const brokers = this.brokerMetadata;
-  async.mapValuesLimit(brokers, this.options.maxAsyncRequests,
+  async.mapValuesLimit(
+    brokers,
+    this.options.maxAsyncRequests,
     (brokerMetadata, brokerId, cb) => {
       const broker = this.brokerForLeader(brokerId);
       if (!broker || !broker.isConnected()) {
@@ -434,7 +436,8 @@ KafkaClient.prototype.getListGroups = function (callback) {
       const request = protocol.encodeListGroups(this.clientId, correlationId);
       this.queueCallback(broker.socket, correlationId, [protocol.decodeListGroups, cb]);
       broker.write(request);
-    }, (err, results) => {
+    },
+    (err, results) => {
       if (err) {
         callback(err);
         return;
@@ -452,7 +455,9 @@ KafkaClient.prototype.getDescribeGroups = function (groups, callback) {
     return callback(new Error('Client is not ready (getDescribeGroups)'));
   }
 
-  async.groupByLimit(groups, this.options.maxAsyncRequests,
+  async.groupByLimit(
+    groups,
+    this.options.maxAsyncRequests,
     (group, cb) => {
       this.sendGroupCoordinatorRequest(group, (err, coordinator) => {
         cb(err || null, coordinator ? coordinator.coordinatorId : undefined);
@@ -464,7 +469,9 @@ KafkaClient.prototype.getDescribeGroups = function (groups, callback) {
         return;
       }
 
-      async.mapValuesLimit(results, this.options.maxAsyncRequests,
+      async.mapValuesLimit(
+        results,
+        this.options.maxAsyncRequests,
         (groups, coordinator, cb) => {
           const broker = this.brokerForLeader(coordinator);
           if (!broker || !broker.isConnected()) {
@@ -481,15 +488,24 @@ KafkaClient.prototype.getDescribeGroups = function (groups, callback) {
             return callback(err);
           }
 
-          callback(null, _.reduce(res, (result, describes, broker) => {
-            _.each(describes, (values, consumer) => {
-              result[consumer] = values;
-              result[consumer].brokerId = broker;
-            });
-            return result;
-          }, {}));
-        });
-    });
+          callback(
+            null,
+            _.reduce(
+              res,
+              (result, describes, broker) => {
+                _.each(describes, (values, consumer) => {
+                  result[consumer] = values;
+                  result[consumer].brokerId = broker;
+                });
+                return result;
+              },
+              {}
+            )
+          );
+        }
+      );
+    }
+  );
 };
 
 KafkaClient.prototype.close = function (callback) {