Emit correct event

src/functions/demux.ts

@@ -1,4 +1,4 @@
-import { DuplexOptions, Duplex, Transform } from "stream";
+import { DuplexOptions, Duplex, Transform, Writable } from "stream";
 
 import { isReadable } from "../helpers";
 
@@ -48,10 +48,11 @@ class Demux extends Duplex {
             ...options,
             transform: (d, _, cb) => {
                 this.push(d);
-                cb(null, d);
+                cb(null);
             },
         });
-        this.once("unpipe", () => this._flush());
+
+        this.on("unpipe", () => this._flush());
     }
 
     public _read(size: number) {}
@@ -87,7 +88,7 @@ class Demux extends Duplex {
                 totalEnded++;
                 if (pipelines.length === totalEnded) {
                     this.push(null);
-                    this.emit("finished");
+                    this.emit("end");
                 }
             });
         });

tests/demux.spec.ts

@@ -724,7 +724,7 @@ test.cb("Demux should send data events", t => {
     });
 });
 
-test.cb("demux() `finish` and `end` propagates", t => {
+test.cb.only("demux() `finish` and `end` propagates", t => {
     interface Chunk {
         key: string;
         mapped: number[];