SOURCE

//take 是一个很简单的 operator，顾名思义就是取前几个元素后就结束，范例如下
var source = Rx.Observable.interval(1000);
var example = source.take(3);

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