本文使用的是angular6内置的rxjs，版本号为6.3.3
concat
通过顺序地发出多个 Observables 的值将它们连接起来，一个接一个的。...const timer1 = interval(1000).pipe(take(10));
const timer2 = interval(2000).pipe(take(6));
const...toArray());
result.subscribe(x => console.log(x));
// 将Observable转换为数组之后的结果
[0, 1, 2, 3, 4, 5,...6, 7, 8, 9, 0, 1, 2, 3, 4, 5, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9]
count
计算源的发送数量，并当源完成时发出该数值。...arr = [12, 9, 2, 21, 11];
from(arr).pipe(count(x => true))
.subscribe(x => console.log(x));
// 结果
// 5
