LimitReader: check if _unread() exists before calling to make limitre…

…ader more flexible, work with any async iterator bump to 1.4.2
webrecorder · Mar 3, 2021 · 34b8383 · 34b8383
1 parent 57ea3b0
commit 34b8383
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/dist/warcio.js b/dist/warcio.js
@@ -3676,7 +3676,9 @@ class LimitReader extends BaseAsyncIterReader
         const [first, remainder] = LimitReader.splitChunk(chunk, this.limit);
         chunk = first;
 
-        this.sourceIter._unread(remainder);
+        if (this.sourceIter._unread) {
+          this.sourceIter._unread(remainder);
+        }
       }
 
       if (chunk.length) {

diff --git a/dist/warcio.min.js b/dist/warcio.min.js
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "warcio",
-  "version": "1.4.1",
+  "version": "1.4.2",
   "main": "index.js",
   "module": "main.js",
   "license": "Apache-2.0",

diff --git a/src/readers.js b/src/readers.js
@@ -457,7 +457,9 @@ class LimitReader extends BaseAsyncIterReader
         const [first, remainder] = LimitReader.splitChunk(chunk, this.limit);
         chunk = first;
 
-        this.sourceIter._unread(remainder);
+        if (this.sourceIter._unread) {
+          this.sourceIter._unread(remainder);
+        }
       }
 
       if (chunk.length) {