- window
- 签名:
window(windowBoundaries: Observable): Observable
- 签名:
- 时间窗口值的 observable 。
- 示例
- 示例 1: 打开由内部 observable 指定的窗口
- 示例
- 其他资源
window
签名: window(windowBoundaries: Observable): Observable
时间窗口值的 observable 。
示例
示例 1: 打开由内部 observable 指定的窗口
( StackBlitz |
jsBin |
jsFiddle )
import { timer } from 'rxjs/observable/timer';import { window, scan, mergeAll } from 'rxjs/operators';// 立即发出值,然后每秒发出值const source = timer(0, 1000);const example = source.pipe(window(interval(3000)));const count = example.pipe(scan((acc, curr) => acc + 1, 0));/*"Window 1:"012"Window 2:"345...*/const subscribe = count.subscribe(val => console.log(`Window ${val}:`));const subscribeTwo = example.pipe(mergeAll()).subscribe(val => console.log(val));
其他资源
- window
- 官方文档 - 使用 window 分割 RxJS observable
- André Staltz
源码: https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/window.ts
