feat: expose import concurrency controls (#1187)

package.json

@@ -42,7 +42,6 @@
   },
   "dependencies": {
     "abort-controller": "^3.0.0",
-    "async-iterator-all": "^1.0.0",
     "async-iterator-to-pull-stream": "^1.3.0",
     "bignumber.js": "^9.0.0",
     "bl": "^4.0.0",
@@ -60,6 +59,7 @@
     "ipld-dag-pb": "^0.18.1",
     "ipld-raw": "^4.0.0",
     "is-ipfs": "~0.6.1",
+    "it-all": "^1.0.1",
     "it-glob": "0.0.7",
     "it-tar": "^1.1.1",
     "it-to-stream": "^0.1.1",

src/add/index.js

@@ -29,6 +29,8 @@ module.exports = configure(({ ky }) => {
     if (options.trickle != null) searchParams.set('trickle', options.trickle)
     if (options.wrapWithDirectory != null) searchParams.set('wrap-with-directory', options.wrapWithDirectory)
     if (options.preload != null) searchParams.set('preload', options.preload)
+    if (options.fileImportConcurrency != null) searchParams.set('file-import-concurrency', options.fileImportConcurrency)
+    if (options.blockWriteConcurrency != null) searchParams.set('block-write-concurrency', options.blockWriteConcurrency)
 
     const res = await ky.post('add', {
       timeout: options.timeout,

src/index.js

@@ -11,7 +11,7 @@ const PeerId = require('peer-id')
 const PeerInfo = require('peer-info')
 const nodeify = require('promise-nodeify')
 const callbackify = require('callbackify')
-const all = require('async-iterator-all')
+const all = require('it-all')
 const toPullStream = require('async-iterator-to-pull-stream')
 const toStream = require('it-to-stream')
 const BufferList = require('bl/BufferList')

src/lib/converters.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const toPull = require('async-iterator-to-pull-stream')
-const all = require('async-iterator-all')
+const all = require('it-all')
 const toStream = require('it-to-stream')
 const { Buffer } = require('buffer')