const observable = Rx.Observable.of(2000, 1000, 3000);

​

// `mergeMap`を実行した Observable（`observable`）が通知する値（`2000`、`1000`、`3000`）に対して

// Observable を生成する関数（`v => Rx.Observable.timer(v).mapTo(v)`）を実行し、

// その戻り値である以下の Observable をマージした Observable を生成する。

// Rx.Observable.timer(2000).mapTo(2000)

// Rx.Observable.timer(1000).mapTo(1000)

// Rx.Observable.timer(3000).mapTo(3000)

const merged = observable.mergeMap(v => Rx.Observable.timer(v).mapTo(v));

​

merged.subscribe(

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

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

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

);

// => "next: 1000"

// => "next: 2000"

// => "next: 3000"

// => "complete"