takeWhile

签名: takeWhile(predicate: function(value, index): boolean): Observable

发出值,直到提供的表达式结果为 false 。

takeWhile - 图1

示例

示例 1: 使用限定条件取值

( jsBin |
jsFiddle )

  1. import { of } from 'rxjs/observable/of';
  2. import { takeWhile } 'rxjs/operators';
  3. // 发出 1,2,3,4,5
  4. const source = of(1, 2, 3, 4, 5);
  5. // 允许值发出直到 source 中的值大于4,然后便完成
  6. const example = source.pipe(takeWhile(val => val <= 4));
  7. // 输出: 1,2,3,4
  8. const subscribe = example.subscribe(val => console.log(val));
示例 2: takeWhile() 和 filter() 的区别

( jsBin |
jsFiddle )

  1. import { of } from 'rxjs/observable/of';
  2. import { takeWhile, filter } 'rxjs/operators';
  3. // 发出 3, 3, 3, 9, 1, 4, 5, 8, 96, 3, 66, 3, 3, 3
  4. const source = of(3, 3, 3, 9, 1, 4, 5, 8, 96, 3, 66, 3, 3, 3);
  5. // 允许值通过直到源发出的值不等于3,然后完成
  6. // 输出: [3, 3, 3]
  7. source
  8. .pipe(takeWhile(it => it === 3))
  9. .subscribe(val => console.log('takeWhile', val))
  10. // 输出: [3, 3, 3, 3, 3, 3, 3]
  11. source
  12. .pipe(filter(it => it === 3))
  13. .subscribe(val => console.log('filter', val));

相关食谱

其他资源


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