1 files changed, 3 insertions, 2 deletions
diff --git a/lib/torrent.js b/lib/torrent.js
index ff4dcdd..b1ff330 100644
--- a/lib/torrent.js
+++ b/lib/torrent.js
@@ -17,7 +17,7 @@ const get = require('simple-get')
 const ImmediateChunkStore = require('immediate-chunk-store')
 const ltDontHave = require('lt_donthave')
 const MemoryChunkStore = require('memory-chunk-store')
-const MultiStream = require('multistream')
+const joinIterator = require('join-async-iterator')
 const parallel = require('run-parallel')
 const parallelLimit = require('run-parallel-limit')
 const parseTorrent = require('parse-torrent')
@@ -29,6 +29,7 @@ const sha1 = require('simple-sha1')
 const throughput = require('throughput')
 const utMetadata = require('ut_metadata')
 const utPex = require('ut_pex') // browser exclude
+const { Readable } = require('streamx')
 
 const File = require('./file.js')
 const Peer = require('./peer.js')
@@ -1784,7 +1785,7 @@ class Torrent extends EventEmitter {
     if (!Array.isArray(streams)) streams = [streams]
     if (!cb) cb = noop
 
-    const readable = new MultiStream(streams)
+    const readable = Readable.from(joinIterator(streams))
     const writable = new ChunkStoreWriteStream(this.store, this.pieceLength)
 
     pump(readable, writable, err => {