const observable = Rx.Observable.of(1, 11);

const observable2 = Rx.Observable.of(2, 12);

const observable3 = Rx.Observable.of(3, 13);

​

// 指定した全ての Observable（`observable`、`observable2`、`observable3`）が`next`通知をしたら、

// 通知された値を配列にまとめて`next`通知する Observable（observableZipped）を生成する。

// 今回、指定した Observable が 1回目に`next`通知をする値はそれぞれ`1`、`2`、`3`であり、

// ２回目に`next`通知をする値は`11`、`12`、`13`である。

// そのため、この Observable が`next`通知する値は`[1, 2, 3]`（１回目）と`[11, 12, 13]`（２回目）である。

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

​

zip.subscribe(

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

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

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

);

// => "next: 1,2,3"

// => "next: 11,12,13"

// => "complete"