RxJS - nを受信した後に値を受信します

Question

排出量をカウントで抑制できる演算子が存在しますか？

私は基本的にスキップコールを繰り返します。下の例では、Skip 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]); 
}