Rxjs-transformation-operator-bufferwhen

RxJS-変換演算子bufferWhen

この演算子は、配列形式で値を提供します。この関数は、バッファーを閉じて、放出し、リセットするタイミングを決定する関数として1つの引数を取ります。

構文

bufferWhen(closing_func: Observable): Observable

パラメーター

*closing_func* -バッファの閉鎖を示すObservableを返す関数。

戻り値

バッファリングされた値の配列を持つオブザーバブルが返されます。

例

これはbufferWhenの実際の例です-

import { fromEvent, interval} from 'rxjs';
import { bufferWhen } from 'rxjs/operators';

let btn = document.getElementById("btnclick");
let btn_clicks = fromEvent(btn, 'click');
let buffered_array = btn_clicks.pipe(bufferWhen(() => interval(5000)));
buffered_array.subscribe(arr => console.log(arr));

*bufferWhen* には、5秒間隔で実行される関数を指定しました。 したがって、5秒ごとに、記録されたすべてのクリックが出力され、リセットされて再び開始されます。

出力

bufferWhen Operator