//first 会取 observable 送出的第 1 个元素之后就直接结束,行为跟 take(1) 一致。
var source = Rx.Observable.interval(1000);
var example = source.first();
example.subscribe({
next: (value) => { console.log(value); },
error: (err) => { console.log('Error: ' + err); },
complete: () => { console.log('complete'); }
});
//last 最后一个