RxJS window

每當(dāng)將源 Observable 值分支為嵌套 Observable 時(shí) windowBoundaries發(fā)出。

window<T>(windowBoundaries: Observable<any>): OperatorFunction<T, Observable<T>>

參量

returns

OperatorFunction<T, Observable<T>>：可觀察到的窗戶 發(fā)射源 Observable 值的 Observable。

描述

就像 buffer，但是發(fā)出嵌套的 Observable 而不是數(shù)組。

返回一個(gè) Observable，它發(fā)出從源 Observable 收集的項(xiàng)目的窗口。輸出 Observable 發(fā)出連接的非重疊窗口。當(dāng) ObservablewindowBoundaries 發(fā)出一個(gè)項(xiàng)目時(shí)，它將發(fā)出當(dāng)前窗口并打開(kāi)一個(gè)新窗口。因?yàn)槊總€(gè)窗口都是一個(gè) Observable，所以輸出是一個(gè)高階 Observable。

例

在每個(gè)1秒的窗口中，最多發(fā)出2次點(diǎn)擊事件

import { fromEvent, interval } from 'rxjs';
import { window, mergeAll, map, take } from 'rxjs/operators';


 const clicks = fromEvent(document, 'click');
 const sec = interval(1000);
 const result = clicks.pipe(
     window(sec),
     map(win => win.pipe(take(2))), // each window has at most 2 emissions
     mergeAll(),              // flatten the Observable-of-Observables
 );
 result.subscribe(x => console.log(x));

也可以看看

• windowCount
• windowTime
• windowToggle
• windowWhen
• buffer