diff options
author | ThaUnknown <6506529+ThaUnknown@users.noreply.github.com> | 2022-07-04 17:36:39 +0300 |
---|---|---|
committer | ThaUnknown <6506529+ThaUnknown@users.noreply.github.com> | 2022-07-04 17:36:39 +0300 |
commit | 5d87d1b32356f6b75ed4f9aefe91f3ddf1ecebdb (patch) | |
tree | 9460b4bc24eecb2297835400a351848f247b3e28 /lib | |
parent | 3a8f901a48503a5c767b6174904e2c062d403a6a (diff) |
fix: drop multi-stream
Diffstat (limited to 'lib')
-rw-r--r-- | lib/torrent.js | 5 |
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 => { |