RxJS - 收到后n的发射值

Question

是否存在能够通过计数抑制排放的操作员？

我基本上想重复跳过调用。在下面的例子中，我想跳过5，发出一个值并重复。

export default function errorHandler(action$){ 
    action$.ofType(types.ERROR) 
    /* After every n emissions received, emit once */ 
    .map(someAction) 
} 

Answer 1

你可以使用bufferCount，这将发出一旦缓冲动作的指定数目。

随着RxJS的术语，节流会涉及到第一缓冲的行动正在发出：

export default function errorHandler(action$){ 
    action$.ofType(types.ERROR) 
    .bufferCount(5) 
    .map((actions) => actions[0]); 
} 

发射最后缓冲的作用，而不是会被称为反跳，在RxJS的术语：

export default function errorHandler(action$){ 
    action$.ofType(types.ERROR) 
    .bufferCount(5) 
    .map((actions) => actions[actions.length - 1]); 
}