我使用RxJS 4来创建Hot Observable,如官方文档中所述
但是RxJS 5迁移指南没有说明如何创建Hot Observable。
const source = Observable.create((observer) => {
asynCall((data) => {
observer.onNext(data)
})
})
const published = source.publish()
published.connect()
published.subscribe((data) => {
console.log(data)
})
Run Code Online (Sandbox Code Playgroud)
使用Rx5,我遇到以下错误:
未被捕获的TypeError:source.publish不是函数(…)