gpt4 book ai didi

javascript - 使用时间和自定义事件进行缓冲

转载 作者:行者123 更新时间:2023-12-03 06:48:02 26 4
gpt4 key购买 nike

我昨天开始使用rxjs。我想实现以下行为:

我希望我的缓冲区能够同时生成时间和自定义事件。想象一下,每 2000 毫秒我的缓冲区就会生成一次(就像标准 bufferWithTime 函数行为),并且对于某些特殊事件,会生成一个缓冲区并重新初始化计时器。

这是一个基本表示:

缓冲区内容A:[1, 2]B:[3, 4, 5] >, C: [6, 7], D: [8, 9]

时间段ABD具有相同的持续时间,2000毫秒。

时间段C较短,因为触发了特殊事件7并产生了缓冲区。

我该怎么做?

最佳答案

你能试试这个( jsfiddle )吗?

// Helper functions
function randomDelay(bottom, top) {
return Math.floor( Math.random() * ( 1 + top - bottom ) ) + bottom;
}

// Simulation of random sequence
var source$ = Rx.Observable
.range(1, 30)
.concatMap(function (x) {
return Rx.Observable.of(x).delay(randomDelay(10,500));
});

var intervalBetween = 1000; // should be 2000ms in your case
var dummyStart$ = Rx.Observable.return({});
var specialEvent$ = Rx.Observable.fromEvent(document, 'click');
var opening$ = dummyStart$.concat(specialEvent$).flatMapLatest(function(x){return Rx.Observable.timer(0, intervalBetween)});
var buffers$ = source$.buffer(opening$).skip(1);

source$.subscribe(function(x){console.log('source', x)})

buffers$.subscribe(function(buffer){
console.log('buffer', buffer);
});

这里的想法是使用带有签名 Rx.Observable.prototype.window(windowBoundaries);buffer 运算符。 。这应该为您提供与 windowBoundaries 信号同步发出的非重叠缓冲区。

有一个小技巧(dummyStart)可以使用错误的specialEvent立即启动计时器。这会产生一个空缓冲区作为第一个值,该值被 skip(1) 删除。

关于javascript - 使用时间和自定义事件进行缓冲,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37635557/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com