fix: add change to end output streams to prevent MaxListenersExceeded…

…Warning
nopersonalspace · Jun 1, 2023 · 7ca4303 · 7ca4303
1 parent 42c96ed
commit 7ca4303
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/unzip.ts b/src/unzip.ts
@@ -364,6 +364,11 @@ export class UnzipStream extends Transform {
           // TODO: Do we really want to end the stream manually like this? Seems to work either way
           // this.entry.end(undefined, encoding);
 
+          // Kill and re-make the outStream. This prevents memory issues and
+          // stops node from emitting MaxListenersExceededWarning
+          this.outStream.end();
+          this.outStream = new PassThrough();
+
           // Queue up next state
           this.mode = Mode.ReadingNextFlag;
           this.chunks = [rest];