feat(breaking change): use stream on stats.bw

Author: hacdias

src/stats/bw.js

@@ -1,21 +1,23 @@
 'use strict'
 
 const promisify = require('promisify-es6')
-const streamToValue = require('../utils/stream-to-value')
+const { Transform } = require('readable-stream')
 
 const transform = function (res, callback) {
-  streamToValue(res, (err, data) => {
-    if (err) {
-      return callback(err)
+  const output = new Transform({
+    objectMode: true,
+    transform(chunk, encoding, cb) {
+      cb(null, {
+        totalIn: chunk.TotalIn,
+        totalOut: chunk.TotalOut,
+        rateIn: chunk.RateIn,
+        rateOut: chunk.RateOut
+      })
     }
-
-    callback(null, {
-      totalIn: data[0].TotalIn,
-      totalOut: data[0].TotalOut,
-      rateIn: data[0].RateIn,
-      rateOut: data[0].RateOut
-    })
   })
+
+  res.pipe(output)
+  callback(null, output)
 }
 
 module.exports = (send) => {

test/stats.spec.js

@@ -49,11 +49,14 @@ describe('stats', function () {
     ipfs.stats.bw((err, res) => {
       expect(err).to.not.exist()
       expect(res).to.exist()
-      expect(res).to.have.a.property('totalIn')
-      expect(res).to.have.a.property('totalOut')
-      expect(res).to.have.a.property('rateIn')
-      expect(res).to.have.a.property('rateOut')
-      done()
+
+      res.once('data', (data) => {
+        expect(data).to.have.a.property('totalIn')
+        expect(data).to.have.a.property('totalOut')
+        expect(data).to.have.a.property('rateIn')
+        expect(data).to.have.a.property('rateOut')
+        done()
+      })
     })
   })