// 2秒後に`1`を通知する Observable

const observable = Rx.Observable.timer(2000).mapTo(1);

// 1秒後に`2`を通知する Observable

const observable2 = Rx.Observable.timer(1000).mapTo(2);

// 3秒後に`3`を通知する Observable

const observable3 = Rx.Observable.timer(3000).mapTo(3);

​

// 複数の Observable（`observable`、`observable2`、`observable3`） をマージする。

// 今回の場合、以下の通知をする Observable が生成される。

// 1秒後に`2`を通知する

// 2秒後に`1`を通知する

// 3秒後に`3`を通知する

const merged = Rx.Observable.merge(observable, observable2, observable3);

​

merged.subscribe(

  x => console.log(`next: ${x}`),

  error => console.error(`error: ${error}`),

  () => console.log('complete')

);

// => "next: 2"

// => "next: 1"

// => "next: 3"

// => "complete"