Function StreamProgressWorker

test/js/asyncprogressqueueworkerstream-test.js:21–33

(t)

  Readable = require('stream').Readable

function StreamProgressWorker(t) {
  Readable.call(this, {objectMode: true})
  var self = this
  // initialize stream from cpp on next tick
  process.nextTick(function () {
    var worker = bindings.doProgress
    worker(5, function(i) {
      self.push(i)
    }, function () {
      self.push(null)
    })
  })
}
util.inherits(StreamProgressWorker, Readable)

StreamProgressWorker.prototype._read = function (data) {