[fix] Ensure _compress() callback is always called (#1618)

Fixes #1617

lib/permessage-deflate.js

@@ -133,6 +133,10 @@ class PerMessageDeflate {
     }
 
     if (this._deflate) {
+      if (this._deflate[kCallback]) {
+        this._deflate[kCallback]();
+      }
+
       this._deflate.close();
       this._deflate = null;
     }
@@ -312,7 +316,9 @@ class PerMessageDeflate {
     zlibLimiter.push((done) => {
       this._compress(data, fin, (err, result) => {
         done();
-        callback(err, result);
+        if (err || result) {
+          callback(err, result);
+        }
       });
     });
   }
@@ -419,6 +425,8 @@ class PerMessageDeflate {
       this._deflate.on('data', deflateOnData);
     }
 
+    this._deflate[kCallback] = callback;
+
     this._deflate.write(data);
     this._deflate.flush(zlib.Z_SYNC_FLUSH, () => {
       if (!this._deflate) {
@@ -438,6 +446,12 @@ class PerMessageDeflate {
 
       if (fin) data = data.slice(0, data.length - 4);
 
+      //
+      // Ensure that the callback will not be called again in
+      // `PerMessageDeflate#cleanup()`.
+      //
+      this._deflate[kCallback] = null;
+
       if (fin && this.params[`${endpoint}_no_context_takeover`]) {
         this._deflate.close();
         this._deflate = null;