Resolve issue #38 & #37

fix readAsPromised - stuck if stream alredy "end" #36 (#38) fix setPromiseItem - no wait input promise !! #37 Co-authored-by: Vyacheslav Skakun <[email protected]>
Faleij · Jan 27, 2024 · 35dfefe · 35dfefe
1 parent eaca536
commit 35dfefe
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/src/JsonStreamStringify.ts b/src/JsonStreamStringify.ts
@@ -130,6 +130,10 @@ function readAsPromised(stream, size) {
   const value = stream.read(size);
   if (value === null) {
     return new Promise((resolve, reject) => {
+      if (stream.readableEnded) {
+        resolve(null);
+        return;
+      }
       const endListener = () => resolve(null);
       stream.once('end', endListener);
       stream.once('error', reject);
@@ -358,11 +362,13 @@ export class JsonStreamStringify extends Readable {
     this.item = {
       async read() {
         if (read) return;
-        read = true;
-        input.then((v) => that.setItem(v, parent, key), (err) => {
+        try {
+          read = true;
+          that.setItem(await input, parent, key);
+        } catch (err) {
           that.emit('error', err);
           that.destroy();
-        });
+        }
       },
     };
   }