fix: handle end and finish events

zazuko · Sep 19, 2024 · 63295b6 · 63295b6
1 parent 44377ac
commit 63295b6
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/packages/core/lib/Pipeline.ts b/packages/core/lib/Pipeline.ts
@@ -116,8 +116,11 @@ class Pipeline extends StreamObject<Stream & { pipeline?: Pipeline }> {
         this.children[index].stream.pipe(child.stream)
       }
 
+      const finished = once(() => this.finish())
+
       this.lastChild.stream.on('error', this.logger.error.bind(this.logger))
-      this.lastChild.stream.on('end', this.finish.bind(this))
+      this.lastChild.stream.on('end', finished)
+      this.lastChild.stream.on('finish', finished)
     } catch (err: any) { // eslint-disable-line @typescript-eslint/no-explicit-any
       this.destroy(err)