fix: drop multi-stream (#174)

* fix: migrate to streamx

* fix: drop multi-stream

* chore: update dep

* chore: bump async iterator ver

Author: ThaUnknown

index.js

@@ -6,12 +6,12 @@ const corePath = require('path')
 const { BlobReadStream } = require('fast-blob-stream')
 const isFile = require('is-file')
 const junk = require('junk')
-const MultiStream = require('multistream')
+const joinIterator = require('join-async-iterator')
 const once = require('once')
 const parallel = require('run-parallel')
 const queueMicrotask = require('queue-microtask')
 const sha1 = require('simple-sha1')
-const { Transform, PassThrough } = require('streamx')
+const { Transform, PassThrough, Readable } = require('streamx')
 
 const getFiles = require('./get-files') // browser exclude
 
@@ -218,7 +218,7 @@ function getPieceList (files, pieceLength, estimatedTorrentLength, opts, cb) {
   let pieceNum = 0
   let ended = false
 
-  const multistream = new MultiStream(streams)
+  const multistream = Readable.from(joinIterator(streams))
   const blockstream = new BlockStream(pieceLength, { zeroPadding: false })
 
   multistream.on('error', onError)

package.json

@@ -22,9 +22,9 @@
     "block-stream2": "^2.1.0",
     "fast-blob-stream": "^1.1.1",
     "is-file": "^1.0.0",
+    "join-async-iterator": "^1.1.1",
     "junk": "^3.1.0",
     "minimist": "^1.2.5",
-    "multistream": "^4.1.0",
     "once": "^1.4.0",
     "piece-length": "^2.0.1",
     "queue-microtask": "^1.2.3",