From 3016ae1e2bf76437485e95df9463edfc8088d620 Mon Sep 17 00:00:00 2001
From: achingbrain <alex@achingbrain.net>
Date: Fri, 29 Nov 2019 10:51:51 +0000
Subject: [PATCH] feat: expose import concurrency controls

---
 package.json          | 2 +-
 src/add/index.js      | 2 ++
 src/index.js          | 2 +-
 src/lib/converters.js | 2 +-
 4 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/package.json b/package.json
index 99103fa69..3c4a51a18 100644
--- a/package.json
+++ b/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",
diff --git a/src/add/index.js b/src/add/index.js
index b1a8bb2a1..df6afbad3 100644
--- a/src/add/index.js
+++ b/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,
diff --git a/src/index.js b/src/index.js
index d9dc89630..939f5986f 100644
--- a/src/index.js
+++ b/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')
diff --git a/src/lib/converters.js b/src/lib/converters.js
index a1ed8a010..4f42b3175 100644
--- a/src/lib/converters.js
+++ b/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')