我有一个服务调用,其响应缓存在我的 Angular 服务中,如下所示:
public cacheMyServiceResponse(): Observable<any> {
return this.appConfig.getEndpoint('myService')
.pipe(
switchMap((endpoint: Endpoint) => this.http.get(endpoint.toUrl())),
tap((body: any) => {
if (body) { // this endpoint can also return a 204 (No Content), where body is null
this.cache = body.myData;
}
}),
take(1),
catchError(error => {
this.errorService.trackError(error.status);
return of(true);
})
);
}
所以我的 http.get 调用的响应将被缓存在一个名为“cache”的全局变量中。
问题是,这个调用可能真的很晚才响应,所以我们想在页面加载后(初始化时)立即调用这个端点。 但是实际的响应,或者我们的调用是否完成(成功或错误),只有当用户单击按钮时我们才需要此信息。当然,在单击按钮的那一刻,响应可能还没有出现,并且在这种情况我愿意等待。 (所以我需要的不仅仅是一个简单的 bool 标志)
所以我想在 ngOnInit 中初始化这个调用,如下所示:
ngOnInit() {
this.myService.cacheMyServiceResponse().subscribe();
}
但是在其他地方我需要知道它是否已经完成了调用,而不需要两次触发我的 http 调用。
onClick() {
this.myService.cacheMyServiceResponse().subscribe(() => {
// call is finished..
});
}
目前该服务将被调用两次。我该怎么做?
PS:我没有故意进行错误处理,我只需要知道服务调用是否完成。
最佳答案
我建议使用ReplaySubject()
并订阅 ReplaySubject()
onClick ,它会等待您的服务发出数据,同时仍然可以订阅,而且如果在服务发出数据之前没有订阅,您将不会错过数据:
yourWaitingData = new ReplaySubject();
subscription;
ngOnInit() {
this.myService.cacheMyServiceResponse().subscribe(res => {
//yourWaitingData only emit when res is return from API call
this.yourWaitingData.next(res)
});
}
然后订阅它:
onClick() {
if(this.subscription){
this.subscription.unsubscribe()
}
this.subscription = this.yourWaitingData.subscribe((x) => {
// subscribed and will wait for data to be emited from service
console.log(x)
});
}
关于Angular - 多次订阅而不触发多个调用?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57374975/