Rxjs等价于Observable.create(subscriber - > {...}).share()

Question

我正在将我的Angular 5应用程序升级到Angular 6,因此从rxjs 5升级到rxjs 6,我在迁移以下代码时遇到了麻烦:

const myObservable = Observable.create(subscriber => {
    // do something with the subscriber
}).share();

特别是我收到这个错误:

类型错误:Observable_1.Observable.create(...)的份额是不是functionTypeError:Observable_1.Observable.create(...)的份额不大.

Answer 1

你需要管道share()如下而不是链接:

const myObservable = Observable.create(subscriber => {
    // do something with the subscriber
}).pipe(share());

还要确保按如下方式导入共享:

import {share} from 'rxjs/operators';