Fix zlib errors during disconnect: check destroyed state

During client disconnect, async zlib callbacks can fire after the
stream is destroyed, causing uncaught errors. Add this.destroyed
checks in Compressor/Decompressor _transform and callbacks to
prevent writing to destroyed streams.

Also suppress compressor/decompressor errors during client shutdown
(this.ended check in error handlers).

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: rom1504

src/client.js

@@ -224,11 +224,15 @@ class Client extends EventEmitter {
   setCompressionThreshold (threshold) {
     if (this.compressor == null) {
       this.compressor = compression.createCompressor(threshold)
-      this.compressor.on('error', (err) => this.emit('error', err))
+      this.compressor.on('error', (err) => {
+        if (!this.ended) this.emit('error', err)
+      })
       this.serializer.unpipe(this.framer)
       this.serializer.pipe(this.compressor).pipe(this.framer)
       this.decompressor = compression.createDecompressor(threshold, this.hideErrors)
-      this.decompressor.on('error', (err) => this.emit('error', err))
+      this.decompressor.on('error', (err) => {
+        if (!this.ended) this.emit('error', err)
+      })
       this.splitter.unpipe(this.deserializer)
       this.splitter.pipe(this.decompressor).pipe(this.deserializer)
     } else {

src/datatypes/minecraft.js

@@ -56,7 +56,12 @@ function readCompressedNbt (buffer, offset) {
 
   const compressedNbt = buffer.slice(offset + 2, offset + 2 + length)
 
-  const nbtBuffer = zlib.gunzipSync(compressedNbt) // TODO: async
+  let nbtBuffer
+  try {
+    nbtBuffer = zlib.gunzipSync(compressedNbt) // TODO: async
+  } catch (err) {
+    throw new PartialReadError('zlib decompress failed: ' + err.message)
+  }
 
   const results = nbt.proto.read(nbtBuffer, 0, 'nbt')
   return {

src/transforms/compression.js

@@ -46,13 +46,15 @@ class Decompressor extends Transform {
   }
 
   _transform (chunk, enc, cb) {
+    if (this.destroyed) return
     const { size, value, error } = readVarInt(chunk, 0)
     if (error) { return cb(error) }
     if (value === 0) {
       this.push(chunk.slice(size))
       return cb()
     } else {
       zlib.unzip(chunk.slice(size), { finishFlush: 2 /*  Z_SYNC_FLUSH = 2, but when using Browserify/Webpack it doesn't exist */ }, (err, newBuf) => { /** Fix by lefela4. */
+        if (this.destroyed) return
         if (err) {
           if (!this.hideErrors) {
             console.error('problem inflating chunk')