var source = Rx.Observable.create(function(observer){

  try {

    observer.next(1)

    observer.next(2)

    observer.next(3)

    setTimeout(() => {

        observer.next('RxJS 30 days!');

    }, 2000)

    //throw 'some exception'

    //observer.complete()

  }catch(e){

    observer.error(e)

  }

});

​

var observer = {

  next: (val) => console.log(val),

  error: () => console.log('出错啦'),

  complete: () => console.log('完成'),

}

var subscribe = source.subscribe(observer);

​

​

var timer = setTimeout(()=>{

  subscribe.unsubscribe();

  console.log('取消订阅')

},2000)