deps: update it-pushable dep

Also updates streaming-iterables dev dep
alanshaw · Aug 6, 2022 · 31a9fd8 · 31a9fd8
1 parent 09c782f
commit 31a9fd8
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -148,7 +148,7 @@
   },
   "dependencies": {
     "it-merge": "^1.0.4",
-    "it-pushable": "^2.0.0",
+    "it-pushable": "^3.1.0",
     "it-stream-types": "^1.0.3"
   },
   "devDependencies": {
@@ -157,6 +157,6 @@
     "it-all": "^1.0.6",
     "it-drain": "^1.0.5",
     "p-defer": "^4.0.0",
-    "streaming-iterables": "^6.0.0"
+    "streaming-iterables": "^7.0.4"
   }
 }
diff --git a/src/index.ts b/src/index.ts
@@ -27,7 +27,9 @@ const duplexPipelineFn = <TSource> (duplex: it.Duplex<TSource>) => {
     const p = duplex.sink(source)
 
     if (p.then != null) {
-      const stream = pushable<TSource>()
+      const stream = pushable<TSource>({
+        objectMode: true
+      })
       p.then(() => {
         stream.end()
       }, (err: Error) => {