//在实务上 takeUntil 很常使用到,他可以在某件事情发生时,让一个 observable 直送出 完成(complete)讯息,范例如下
var source = Rx.Observable.interval(1000);
var click = Rx.Observable.fromEvent(document.getElementById('demo'), 'click');
var example = source.takeUntil(click);
example.subscribe({
next: (value) => { console.log(value); },
error: (err) => { console.log('Error: ' + err); },
complete: () => { console.log('complete'); }
});
<button id="demo">anniu</button>