change code style

moleculerjs · Oct 1, 2023 · cad067d · cad067d
1 parent a0cec5f
commit cad067d
Showing 1 changed file with 31 additions and 25 deletions.
diff --git a/src/transit.js b/src/transit.js
@@ -895,23 +895,23 @@ class Transit {
  } else {
  chunks.push(chunk);
  }
- const publishMap = chunks.map(ch => {
- const copy = Object.assign({}, payload);
- copy.seq = ++payload.seq;
- copy.stream = true;
- copy.params = ch;
 
- this.logger.debug(
- `=> Send stream chunk ${requestID}to ${nodeName} node. Seq: ${copy.seq}`
- );
-
- return this.publish(new Packet(P.PACKET_REQUEST, ctx.nodeID, copy));
- });
-
- return this.Promise.all(publishMap).then(
- () => stream.resume(),
- publishCatch
- );
+ return this.Promise.all(
+ chunks.map(ch => {
+ const copy = Object.assign({}, payload);
+ copy.seq = ++payload.seq;
+ copy.stream = true;
+ copy.params = ch;
+
+ this.logger.debug(
+ `=> Send stream chunk ${requestID}to ${nodeName} node. Seq: ${copy.seq}`
+ );
+
+ return this.publish(new Packet(P.PACKET_REQUEST, ctx.nodeID, copy));
+ })
+ )
+ .then(() => stream.resume())
+ .catch(publishCatch);
  });
 
  stream.on("end", () => {
@@ -1127,17 +1127,23 @@ class Transit {
  } else {
  chunks.push(chunk);
  }
- const publishMap = chunks.map(ch => {
- const copy = Object.assign({}, payload);
- copy.seq = ++payload.seq;
- copy.stream = true;
- copy.data = ch;
 
- this.logger.debug(`=> Send stream chunk to ${nodeID} node. Seq: ${copy.seq}`);
+ return this.Promise.all(
+ chunks.map(ch => {
+ const copy = Object.assign({}, payload);
+ copy.seq = ++payload.seq;
+ copy.stream = true;
+ copy.data = ch;
 
- return this.publish(new Packet(P.PACKET_RESPONSE, nodeID, copy));
- });
- return this.Promise.all(publishMap).then(() => stream.resume(), publishCatch);
+ this.logger.debug(
+ `=> Send stream chunk to ${nodeID} node. Seq: ${copy.seq}`
+ );
+
+ return this.publish(new Packet(P.PACKET_RESPONSE, nodeID, copy));
+ })
+ )
+ .then(() => stream.resume())
+ .catch(publishCatch);
  });
 
  stream.on("end", () => {