merge

签名: merge(input: Observable): Observable

将多个 observables 转换成单个 observable 。

此操作符可以既有静态方法，又有实例方法！

如果产生值的顺序是首要考虑的，那么试试用 concat 来代替！

示例

示例 1: 使用静态方法合并多个 observables

( StackBlitz |
jsBin |
jsFiddle )

import { mapTo } from 'rxjs/operators';
import { interval } from 'rxjs/observable/interval';
import { merge } from 'rxjs/observable/merge';
// 每2.5秒发出值
const first = interval(2500);
// 每2秒发出值
const second = interval(2000);
// 每1.5秒发出值
const third = interval(1500);
// 每1秒发出值
const fourth = interval(1000);
// 从一个 observable 中发出输出值
const example = merge(
  first.pipe(mapTo('FIRST!')),
  second.pipe(mapTo('SECOND!')),
  third.pipe(mapTo('THIRD')),
  fourth.pipe(mapTo('FOURTH'))
);
// 输出: "FOURTH", "THIRD", "SECOND!", "FOURTH", "FIRST!", "THIRD", "FOURTH"
const subscribe = example.subscribe(val => console.log(val));

示例 2: 使用实例方法合并2个 observables

( StackBlitz |
jsBin |
jsFiddle )

import { merge } from 'rxjs/operators';
import { interval } from 'rxjs/observable/interval';
// 每2.5秒发出值
const first = interval(2500);
// 每1秒发出值
const second = interval(1000);
// 作为实例方法使用
const example = first.pipe(merge(second));
// 输出: 0,1,0,2....
const subscribe = example.subscribe(val => console.log(val));

其他资源

• merge - 官方文档
• 使用 merge 处理多个流 - John Linquist
• 使用 merge1 共享网络请求 - André Staltz
• 组合操作符: merge - André Staltz

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