finish event -> _finish

davedoesdev · Apr 3, 2020 · 1a26c5e · 1a26c5e
1 parent 3d2aafd
commit 1a26c5e
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/test/memory-duplex.js b/test/memory-duplex.js
@@ -5,10 +5,6 @@ function RightDuplex(left, options)
 {
     Duplex.call(this, options);
     this.left = left;
-    this.on('finish', function ()
-    {
-        left.push(null);
-    });
     this._orig_emit = this.emit;
     this.emit = function (type)
     {
@@ -27,6 +23,12 @@ function RightDuplex(left, options)
 
 util.inherits(RightDuplex, Duplex);
 
+RightDuplex.prototype._final = function (cb)
+{
+    this.left.push(null);
+    cb();
+};
+
 RightDuplex.prototype._read = function ()
 {
     if (this._cb)
@@ -53,10 +55,6 @@ function LeftDuplex(options)
 {
     Duplex.call(this, options);
     this.right = new RightDuplex(this, options);
-    this.on('finish', function ()
-    {
-        this.right.push(null);
-    });
     this._orig_emit = this.emit;
     this.emit = function (type)
     {
@@ -76,6 +74,11 @@ function LeftDuplex(options)
 
 util.inherits(LeftDuplex, Duplex);
 
+LeftDuplex.prototype._final = function (cb)
+{
+    this.right.push(null);
+};
+
 LeftDuplex.prototype._read = function ()
 {
     if (this._cb)