我有一个高地流逐行读取文件,我想将其减慢到每秒一个块。我浏览了文档,发现的唯一功能是throttle()
and debounce()
。这两个值都下降了。我需要保持我所有的价值观,只是放慢速度。
问问题
193 次
2 回答
3
我建议将块映射到延迟流并对其进行排序:
var _ = require('highland');
function delay(x) {
return _(function (push, next) {
setTimeout(function () {
push(null, x);
push(null, _.nil);
}, 1000);
});
}
_([1, 2, 3, 4]).map(delay).series().each(_.log);
这里使用的延迟函数似乎很容易概括,所以如果你有兴趣发送拉请求,我很乐意查看它:)
于 2014-05-22T09:22:29.730 回答
0
这与 Caolan 的功能版本相同,但可配置。我为自己制作了另一个版本,跳过了第一个元素的延迟。
var _ = require('highland');
function delay(delayMs) {
return function(x) {
return _(function(push, next) {
return setTimeout((function() {
push(null, x);
return push(null, _.nil);
}), delayMs);
});
};
}
_([1, 2, 3, 4]).map(delay(1000)).series().each(_.log);
于 2015-07-13T15:49:24.670 回答