RxJS_Creation_Operator_zip.js

// Operators - zip
var source = Rx.Observable.interval(500).take(3);
var newest = Rx.Observable.interval(300).take(6);

var example = source.zip(newest, (x, y) => x + y);

example.subscribe({
    next: (value) => { console.log(value); },
    error: (err) => { console.log('Error: ' + err); },
    complete: () => { console.log('complete'); }
});
// 0
// 2
// 4
// complete

//--
var source = Rx.Observable.from('ABCDE');
var source2 = Rx.Observable.interval(100);

var example = source.zip(source2, (x, y) => x);

example.subscribe({
    next: (value) => { console.log(value); },
    error: (err) => { console.log('Error: ' + err); },
    complete: () => { console.log('complete'); }
});
//A
//B
//C
//D
//E
//complete

/*解釋:
等待和執行同順位的 observable
其中一個 observable 丟出 complete 時，全部結束
*/