如何创建一个RxJS缓冲区来对NodeJS中的元素进行分组，但不依赖于永远的运行间隔？

建议的实现，使用

delay

function emits(who){  return function (x) { console.log([who, "emits"].join(" ") + " " + x + " click(s)");};}var source = Rx.Observable.fromEvent(document.body, 'click');console.log("running");var delayedSource$ = source.delay(1200);var buffered$ = source     .buffer(function () { return  delayedSource$;}).map(function(clickBuffer){return clickBuffer.length;})buffered$.subscribe(emits("buffer"));

jsbin在这里：http
://jsbin.com/wilurivehu/edit?html,js,console,output