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

Question

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

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

这是一个基本表示:

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

时间段A、B、D具有相同的持续时间，2000毫秒。

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

我该怎么做？

Answer 1

你能试试这个( 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) 删除。