• windowTime
    • 签名: windowTime(windowTimeSpan: number, windowCreationInterval: number, scheduler: Scheduler): Observable
  • 在每个提供的时间跨度内,收集源 obsercvable 中的值的 observable 。
    • 示例
      • 示例 1: 每个指定持续时间都会开启新窗口
  • 其他资源

    windowTime

    签名: windowTime(windowTimeSpan: number, windowCreationInterval: number, scheduler: Scheduler): Observable

    在每个提供的时间跨度内,收集源 obsercvable 中的值的 observable 。

    windowTime - 图1

    示例

    示例 1: 每个指定持续时间都会开启新窗口

    ( StackBlitz |
    jsBin |
    jsFiddle )

    1. import { timer } from 'rxjs/observable/timer';
    2. import { windowTime, tap, mergeAll } from 'rxjs/operators';
    3. // 立即发出值,然后每秒发出值
    4. const source = timer(0, 1000);
    5. const example = source.pipe(
    6. // 每3秒开启一个新窗口
    7. windowTime(3000),
    8. tap(_ => console.log('NEW WINDOW!'))
    9. );
    10. const subscribeTwo = example
    11. .pipe(
    12. // 窗口发出嵌套的 observable
    13. mergeAll()
    14. /*
    15. 输出:
    16. "NEW WINDOW!"
    17. 0
    18. 1
    19. 2
    20. "NEW WINDOW!"
    21. 3
    22. 4
    23. 5
    24. */
    25. )
    26. .subscribe(val => console.log(val));

    其他资源

    • windowTime :newspaper: - 官方文档

    :file_folder: 源码: https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/windowTime.ts