无需重新计算公共部分的多个订阅

Question

const ex = ajax.getJSON('https://httpbin.org/get?a=24');
ex.pipe(pluck('args')).subscribe(x => console.log('Args: ', x));
ex.pipe(pluck('headers')).subscribe(x => console.log('Headers: ', x));

上面的代码（StackBlitz）为每个订阅启动两个 ajax 请求。

为所有现有订阅仅启动一个可观察管道/链的正确方法是什么？

我可以通过为 ajax(StackBlitz) 引入 Promise 来实现：

const p = new Promise(resolve => {
  ajax.getJSON('https://httpbin.org/get?a=24')
  .subscribe(res => resolve(res));
});

from(p).pipe(pluck('args')).subscribe(x => console.log('Args: ', x));
from(p).pipe(pluck('headers')).subscribe(x => console.log('Headers: ', x));

但我相信一定有更方便的方式。

Answer 1

来自 cmets 的shareReplay 解决了我的问题：

const src = tag => of(42)
  .pipe(tap(_ => console.info(tag, 'source called')));

const ex = src('shareReplay').pipe(
  shareReplay(1)
);

ex.subscribe(x => console.log('sa:', x));
ex.subscribe(x => console.log('sb:', x));

shareReplay source called
sa: 42
sb: 42

Full demo

Answer 2

您可以为此使用publish operator：

const ex = ajax.getJSON('https://httpbin.org/get?a=24').pipe(publish());
ex.pipe(pluck('args')).subscribe(x => console.log('Args: ', x));
ex.pipe(pluck('headers')).subscribe(x => console.log('Headers: ', x));
ex.connect();

ajax 请求只会发生一次，并且仅在调用connect() 方法之后（stackblitz demo）。