安装

npm install rxjs
yarn add rxjs

导入整个核心功能集

import Rxjs from 'rxjs/Rx'

创建Observables

在外部产生新事件

var myObservable = new Rx.Subject()
myObservable.subscribe(value => console.log(value))
myObservable.next('foo')

在内部产生新事件

var myObservable = new Rx.Observable.create(observer => {
 observer.next('foo')
 setTimeout(() => observer.next('bar'), 1000)
})
myObservable.subscribe(value => console.log(value))