diff --git a/lib/permessage-deflate.js b/lib/permessage-deflate.js index 7d7209b9e..74bf14a23 100644 --- a/lib/permessage-deflate.js +++ b/lib/permessage-deflate.js @@ -376,12 +376,11 @@ class PerMessageDeflate { this._inflate[kTotalLength] ); + this._inflate[kTotalLength] = 0; + this._inflate[kBuffers] = []; + if (fin && this.params[`${endpoint}_no_context_takeover`]) { - this._inflate.close(); - this._inflate = null; - } else { - this._inflate[kTotalLength] = 0; - this._inflate[kBuffers] = []; + this._inflate.reset(); } callback(null, data); @@ -448,12 +447,11 @@ class PerMessageDeflate { // this._deflate[kCallback] = null; + this._deflate[kTotalLength] = 0; + this._deflate[kBuffers] = []; + if (fin && this.params[`${endpoint}_no_context_takeover`]) { - this._deflate.close(); - this._deflate = null; - } else { - this._deflate[kTotalLength] = 0; - this._deflate[kBuffers] = []; + this._deflate.reset(); } callback(null, data);