From 6490f1cbe8bbee69ee2e63ff4ddc331c2a2c85c3 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B2=B1=E9=B9=BF?= <gattaca.yl@antgroup.com>
Date: Thu, 17 Mar 2022 17:18:27 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=88=A0=E9=99=A4=E7=94=A8=E6=88=B7?=
 =?UTF-8?q?=E4=BC=A0=E5=8F=82=E7=9B=B8=E5=85=B3=E9=94=99=E8=AF=AF=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/server/server.js | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/lib/server/server.js b/lib/server/server.js
index cb32323..cfae48a 100644
--- a/lib/server/server.js
+++ b/lib/server/server.js
@@ -88,7 +88,7 @@ class RpcServer extends Base {
   }
 
   get listenPorts() {
-    return [this.publishPort];
+    return [ this.publishPort ];
   }
 
   get logger() {
@@ -188,7 +188,7 @@ class RpcServer extends Base {
           this._handleUncaughtError();
         },
       });
-      Promise.all(this._servers.map(server => awaitFirst(server, ['listening', 'error'])))
+      Promise.all(this._servers.map(server => awaitFirst(server, [ 'listening', 'error' ])))
         .then(() => {
           this.emit('listening');
           this.ready(true);
@@ -254,7 +254,7 @@ class RpcServer extends Base {
     this._connections.set(key, conn);
     conn.on('request', req => {
       this._handleRequest(req, conn).catch(err => {
-        const { packetId, packetType, className, options, meta, ctx } = req
+        const { packetId, packetType, className, options, meta, ctx } = req;
         const { targetAppName, methodName, serverSignature, interfaceName, methodArgSigs, requestProps } = req.data;
         err.req = { packetId, packetType, className, options, meta, ctx, data: { targetAppName, methodName, serverSignature, interfaceName, methodArgSigs, requestProps } };
         this.emit('error', err);