Beautify the code.

jmkristian · Jun 11, 2024 · 8d6ab3e · 8d6ab3e
1 parent f65b640
commit 8d6ab3e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/raw.js b/raw.js
@@ -104,7 +104,7 @@ class RawSocket extends Stream.Duplex {
                 this.log.trace('< %j', packet);
                 this.isReading = this.push(packet);
             } else {
-                this.log.debug('buffer overflow %s', guts.getFrameSummary(frame));
+                this.log.debug('receive buffer overflow %s', guts.getFrameSummary(frame));
             }
         } catch(err) {
             this.log.debug('onFrameFromAGW(%s)', guts.getFrameSummary(frame));

diff --git a/server.js b/server.js
@@ -335,7 +335,7 @@ class Throttle extends Stream.Writable {
         sender.on('notFull', function() {
             that.sendBuffer();
         });
-        this.on('close', function() {that._closed = true;});
+        this.once('close', function() {that.isClosed = true;});
         this.on('pipe', function(from) {
             that.log.trace('pipe from %s', from.constructor.name);
         });
@@ -434,7 +434,7 @@ class Throttle extends Stream.Writable {
 
     _destroy(err, callback) {
         this.log.debug('_destroy(%s, %s)', err || '', typeof callback);
-        if (!this._closed) this.emit('close');
+        if (!this.isClosed) this.emit('close');
         if (callback) callback();
     }
 } // Throttle
@@ -719,8 +719,8 @@ class Connection extends Stream.Duplex {
         this.remoteAddress = toAGW.theirCall;
         this._pushable = false;
         const that = this;
-        this.on('end', function() {that._ended = true;});
-        this.on('close', function() {that._closed = true;});
+        this.once('end', function() {that.isEnded = true;});
+        this.once('close', function() {that.isClosed = true;});
         this.on('pipe', function(from) {
             that.log.trace('pipe from %s', from.constructor.name);
         });
@@ -740,7 +740,7 @@ class Connection extends Stream.Duplex {
             this.destroy();
             break;
         case 'D': // data
-            if (this._closed) {
+            if (this.isClosed) {
                 this.emit('error', newError('received data after close '
                                             + getDataSummary(frame.data)));
             } else if (!this._pushable) {
@@ -776,8 +776,8 @@ class Connection extends Stream.Duplex {
         // The documentation seems to say this.destroy() should emit
         // 'end' and 'close', but I find that doesn't always happen.
         // This works reliably:
-        if (!this._ended) this.emit('end');
-        if (!this._closed) this.emit('close');
+        if (!this.isEnded) this.emit('end');
+        if (!this.isClosed) this.emit('close');
         if (callback) callback(err);
     }