fix(SmartDuplex): Fix stream termination when reading from a web readable stream

2024-10-16 02:28:31 +02:00
parent 4fc82d0dc6
commit a225188e24
4 changed files with 8 additions and 3 deletions
--- a/ts/smartstream.classes.smartduplex.ts
+++ b/ts/smartstream.classes.smartduplex.ts
@@ -68,7 +68,7 @@ export class SmartDuplex<TInput = any, TOutput = any> extends Duplex {
        }
        reader.releaseLock();
        if (done) {
-          smartDuplex.end();
+          smartDuplex.push(null);
        }
      },
    });