RxJs v5 in Angular5 - clickStream.bufer( () => clickStream.throttleTime(250))等失败

Question

我怎样才能做到以下几点？

let button = document.querySelector('.this');
let clickStream = Observable.fromEvent(button, 'click');
let multiClickStream = clickStream
   .buffer(() => { return clickStream.throttleTime(250); } )
   .map(function(list) { return list.length; })
   .filter(function(x) { return x >= 2; });

错误信息是：

TS2345:类型'()=> void‘的参数不能分配给类型=>的参数。属性'_isScalar‘在类型()=>void中缺失

像".buffer(function() { return clickStream.throttleTime(250); }) "这样的替代方案也会产生类似的错误。

我也尝试过throttle(250)，但这两种方法都不起作用。

Answer 1

看起来，您希望使用接受函数作为参数的bufferWhen。

否则，只需将可观察到的直接传递给buffer，而不包装它：

...
.buffer(clickStream.throttleTime(250))