RxJS windowToggle

從以下位置將源 Observable 值分支為嵌套的 Observable 從發(fā)射 openings和結(jié)束時(shí)的輸出 closingSelector 發(fā)出。

windowToggle<T, O>(openings: Observable<O>, closingSelector: (openValue: O) => Observable<any>): OperatorFunction<T, Observable<T>>

參量

returns

OperatorFunction<T, Observable<T>>：可觀察到的窗戶 是可觀察的。

Description

It's like bufferToggle, but emits a nested Observable instead of an array.

返回一個(gè) Observable，它發(fā)出從源收集到的項(xiàng)目的窗口 可觀察的。 輸出 Observable 發(fā)出包含這些項(xiàng)目的窗口 由源發(fā)出的時(shí)間在 openings Observable 發(fā)出一個(gè)項(xiàng)目，當(dāng) Observable 返回 closingSelector發(fā)射一個(gè)物品。

例

每隔一秒鐘，從接下來(lái)的 500ms 發(fā)出點(diǎn)擊事件

import { fromEvent, interval, EMPTY } from 'rxjs';
import { windowToggle, mergeAll } from 'rxjs/operators';


const clicks = fromEvent(document, 'click');
const openings = interval(1000);
const result = clicks.pipe(
  windowToggle(openings, i => i % 2 ? interval(500) : EMPTY),
  mergeAll()
);
result.subscribe(x => console.log(x));

也可以看看

• window
• windowCount
• windowTime
• windowWhen
• bufferToggle