fix(common:stream): always call cb in _transform

bluesky-social · Feb 19, 2024 · 7b53e73 · 7b53e73
1 parent 2b1c66e
commit 7b53e73
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/packages/common/src/streams.ts b/packages/common/src/streams.ts
@@ -73,8 +73,9 @@ export class MaxSizeChecker extends Transform {
   _transform(chunk: Uint8Array, _enc: BufferEncoding, cb: TransformCallback) {
     this.totalSize += chunk.length
     if (this.totalSize > this.maxSize) {
-      return this.destroy(this.createError())
+      cb(this.createError())
+    } else {
+      cb(null, chunk)
     }
-    return cb(null, chunk)
   }
 }