我对 RxJS 有点陌生,并且在 Observable 上使用 map
时遇到问题,这导致上游 Observable 被多次调用(即 HTTP 请求)。
我有以下示例:
https://stackblitz.com/edit/angular-rxjs-playground-uxygsb?file=app%2Fapp.component.ts
主要内容如下
function simulateHttp(val: any, delay:number) {
return Observable.of(val)
.delay(delay);
}
function timeLog(msg) {
console.log(`${new Date().toISOString()}: ${msg}`);
}
const timerStream: Observable<number> = IntervalObservable
.create(8000)
const manualRefreshStream = new Subject<any>();
const combinedTriggerStream: Observable<any> = Observable.merge(timerStream, manualRefreshStream);
const httpResultStream = combinedTriggerStream.switchMap(v => {
return simulateHttp('http ' + v, 3000);
});
const dataStream = httpResultStream
.map(v => `*${v}*`)
.map(v => `#${v}#`);
基本上,只要我通过 httpResult
流上的 map
进行转换,我就会多次调用 simulateHttp
方法。
我四处搜索,似乎 share
可能是解决方案,但我不太了解把它放在哪里以及为什么。
最佳答案
我设法通过执行删除了多个调用
const httpResultStream = combinedTriggerStream
.switchMap(v => simulateHttp('http ' + v, 3000))
.share();
仍然不确定我为什么需要这个。
我还发现这篇文章很有帮助,尽管它与我的问题无关 https://blog.angular-university.io/rxjs-switchmap-operator/
关于javascript - RxJs map函数导致upstream observable被多次调用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/49208171/