New file |
0,0 → 1,65 |
/* |
Copyright (c) 2004-2006, The Dojo Foundation |
All Rights Reserved. |
|
Licensed under the Academic Free License version 2.1 or above OR the |
modified BSD license. For more information on Dojo licensing, see: |
|
http://dojotoolkit.org/community/licensing.shtml |
*/ |
|
dojo.provide("dojo.lang.timing.Streamer"); |
dojo.require("dojo.lang.timing.Timer"); |
dojo.lang.timing.Streamer = function (input, output, interval, minimum, initialData) { |
var self = this; |
var queue = []; |
this.interval = interval || 1000; |
this.minimumSize = minimum || 10; |
this.inputFunction = input || function (q) { |
}; |
this.outputFunction = output || function (point) { |
}; |
var timer = new dojo.lang.timing.Timer(this.interval); |
var tick = function () { |
self.onTick(self); |
if (queue.length < self.minimumSize) { |
self.inputFunction(queue); |
} |
var obj = queue.shift(); |
while (typeof (obj) == "undefined" && queue.length > 0) { |
obj = queue.shift(); |
} |
if (typeof (obj) == "undefined") { |
self.stop(); |
return; |
} |
self.outputFunction(obj); |
}; |
this.setInterval = function (ms) { |
this.interval = ms; |
timer.setInterval(ms); |
}; |
this.onTick = function (obj) { |
}; |
this.start = function () { |
if (typeof (this.inputFunction) == "function" && typeof (this.outputFunction) == "function") { |
timer.start(); |
return; |
} |
dojo.raise("You cannot start a Streamer without an input and an output function."); |
}; |
this.onStart = function () { |
}; |
this.stop = function () { |
timer.stop(); |
}; |
this.onStop = function () { |
}; |
timer.onTick = this.tick; |
timer.onStart = this.onStart; |
timer.onStop = this.onStop; |
if (initialData) { |
queue.concat(initialData); |
} |
}; |
|