// 通知回数４回

const observable = Rx.Observable.of(1, 2, 3, 4);

// 通知回数３回

const observable2 = Rx.Observable.of(5, 6, 7);

// 通知回数無限

const observable3 = Rx.Observable.interval(1000);

​

// 今回指定した Observable の中で、`next`通知回数が１番少ないのは`observable2`である。

// そのため、この Observable が`next`通知する回数は３回

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,5,0"

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

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

// この時点で`observable2`が`complete`通知をするので、"complete"が出力される

// => "complete"