rxjs6 'share()‘不适用于’of(.)‘？

Question

为什么用of(...)创建的可观察到的用户不能在多个订阅者之间共享源代码？timer(...)和Observable.create(...)的工作就像预期的那样。我在文件里找不到任何关于这件事的东西。

https://stackblitz.com/edit/typescript-cygjdt?file=index.ts&devtoolsheight=100

Answer 1

它可以工作，但它是同步的，所以在您的示例中：

// of
const ofSource = of('hi');
const ofExample = ofSource.pipe(
  tap(() => console.log('***SIDE EFFECT - OF***'))
);

const ofSharedExample = ofExample.pipe(share());

ofSharedExample.subscribe(() => console.log('of sub 1'));
ofSharedExample.subscribe(() => console.log('of sub 2'));

第一个订阅是在订阅第二个订阅之前完成的。因此，share将取消订阅底层的可观测性，因为没有其他订阅者可以与其共享可观测到的内容。

但是，如果添加observeOn(asyncScheduler) (或其他异步行为)，您将“延迟”订阅并获得共享的of。

https://stackblitz.com/edit/typescript-xcwyew?file=index.ts