2 var util = require('util')
3 var stream = require('readable-stream')
4 var delegate = require('delegates')
5 var Tracker = require('./tracker.js')
7 var TrackerStream = module.exports = function (name, size, options) {
8 stream.Transform.call(this, options)
9 this.tracker = new Tracker(name, size)
11 this.id = this.tracker.id
12 this.tracker.on('change', delegateChange(this))
14 util.inherits(TrackerStream, stream.Transform)
16 function delegateChange (trackerStream) {
17 return function (name, completion, tracker) {
18 trackerStream.emit('change', name, completion, trackerStream)
22 TrackerStream.prototype._transform = function (data, encoding, cb) {
23 this.tracker.completeWork(data.length ? data.length : 1)
28 TrackerStream.prototype._flush = function (cb) {
33 delegate(TrackerStream.prototype, 'tracker')