Rx.Observable.prototype.concat(...args)
拼接所有指定可观察序列,创建一个输出Observable,它会按拼接顺序发出所有值。
参数
args
(arguments
|Array
): 接受一个数组或单个Observable
参数.
返回值
(Observable
): 返回一个按拼接顺序发出所有值的Observable
例
var timer1 = Rx.Observable.interval(1000).take(10);
var timer2 = Rx.Observable.interval(2000).take(6);
var timer3 = Rx.Observable.interval(500).take(10);
var result = timer1.concat(timer2, timer3);
result.subscribe(x => console.log(x));
// 结果如下:
// -1000ms-> 0 -1000ms-> 1 -1000ms-> ... 9
// -2000ms-> 0 -2000ms-> 1 -2000ms-> ... 5
// -500ms-> 0 -500ms-> 1 -500ms-> ... 9