refactor: convert addReadableStream

License: MIT
Signed-off-by: Alan Shaw <alan.shaw@protocol.ai>

Author: Alan Shaw

package.json

@@ -61,6 +61,7 @@
     "is-stream": "^2.0.0",
     "iso-stream-http": "~0.1.2",
     "iso-url": "~0.4.6",
+    "it-to-stream": "^0.1.1",
     "iterable-ndjson": "^1.1.0",
     "just-kebab-case": "^1.1.0",
     "just-map-keys": "^1.1.0",

src/lib/iterable.js

@@ -1,6 +1,7 @@
 'use strict'
 
 const toPull = require('async-iterator-to-pull-stream')
+const toStream = require('it-to-stream')
 
 exports.collectify = fn => async (...args) => {
   const items = []
@@ -12,3 +13,7 @@ exports.pullify = {
   source: fn => (...args) => toPull(fn(...args)),
   transform: fn => (...args) => toPull.transform(source => fn(source, ...args))
 }
+
+exports.streamify = {
+  transform: fn => (...args) => toStream.transform(source => fn(source, ...args), { objectMode: true })
+}

src/utils/load-commands.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const nodeify = require('promise-nodeify')
-const { collectify, pullify } = require('../lib/iterable')
+const { collectify, pullify, streamify } = require('../lib/iterable')
 
 function requireCommands () {
   return {
@@ -16,8 +16,10 @@ function requireCommands () {
         return nodeify(add(input, options), callback)
       }
     },
-    // TODO: convert
-    addReadableStream: require('../files-regular/add-readable-stream'),
+    addReadableStream: (_, config) => {
+      const add = require('../add')(config)
+      return streamify.transform(add)
+    },
     addPullStream: (_, config) => {
       const add = require('../add')(config)
       return pullify.transform(add)