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

Author: hacdias

Diff for: SPEC/STATS.md

@@ -25,7 +25,9 @@ Where:
   - `poll` is used to print bandwidth at an interval.
   - `interval` is the time interval to wait between updating output, if `poll` is true.
 
-`callback` must follow `function (err, stats) {}` signature, where `err` is an error if the operation was not successful. `stats` is an Object containing the following keys:
+If `poll` is `true`, then `callback` must follow `function (err, stream) {}` signature, where `err` is an error if the operation was not successful and `stream` is a Readable Stream where you can listen to the event `data` with a listener that must follow `function (stat) {}` signature.
+
+Otherwise, `callback` must follow `function (err, stat) {}` signature, where `err` is an error and `stat` is an Object containing the following keys:
 
 - `totalIn`
 - `totalOut`

Diff for: js/src/stats.js

@@ -95,6 +95,26 @@ module.exports = (common) => {
       })
     })
 
+    it('.bw Poll', (done) => {
+      if (!withGo) {
+        console.log('Not supported in js-ipfs yet')
+        return done()
+      }
+
+      ipfs.stats.bw({poll: true}, (err, res) => {
+        expect(err).to.not.exist()
+        expect(res).to.exist()
+
+        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()
+        })
+      })
+    })
+
     it('.bw Promise', () => {
       if (!withGo) {
         console.log('Not supported in js-ipfs yet')
@@ -107,6 +127,26 @@ module.exports = (common) => {
         expect(res).to.have.a.property('totalOut')
         expect(res).to.have.a.property('rateIn')
         expect(res).to.have.a.property('rateOut')
+        done()
+      })
+    })
+
+    it('.bw Promise Poll', (done) => {
+      if (!withGo) {
+        console.log('Not supported in js-ipfs yet')
+        return
+      }
+
+      return ipfs.stats.bw({poll: true}).then((res) => {
+        expect(res).to.exist()
+
+        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()
+        })
       })
     })