搬运文章： https://www.jianshu.com/p/16be96d69143

RxJS 是基于事件流的管理库，通俗一点说，就是我们无法一次性拿到全部数据，数据是以流的形式分部到达的，每次到达可能会有 N 个观察者被触发

var observable = Rx.Observable.create(
  function (observer) {
    observer.next(1);
    observer.next(2);
    observer.next(3);
    setTimeout(() => {
        observer.next(4);
        observer.complete();
    }, 1000);
});

observable.subscribe(function(x){
    console.log(x)；
});

setTimeout(() => {
    observable.subscribe(function (y){
        console.log(y);
    });
}, 1000);

// 理想情况
//var source = Rx.Observable.from([1,2,3,4,5]);
//var example = source.map(x => x + 1);