From 0e44e2827367c0c9585e1f7beb4316679d1eff40 Mon Sep 17 00:00:00 2001
From: Alex Potsides <alex@achingbrain.net>
Date: Sat, 6 Aug 2022 12:46:39 +0100
Subject: [PATCH] deps: update it-pushable dep (#42)

Also updates streaming-iterables dev dep
---
 package.json | 4 ++--
 src/index.ts | 4 +++-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/package.json b/package.json
index 7c4aa43..7ef5671 100644
--- 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
index c4a5e84..dba6045 100644
--- 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) => {