如何在可观察变量的基础上进行单个成功回调，同时允许每个可观察变量具有自己的成功/错误块？我有一个动态的AJAX调用列表，每个调用都需要使用回调方法。在每个AJAX调用完成之后，我还希望有一个回调方法。我尝试使用zip，但是AJAX调用被调用了两次。
例：
var possibleRequest1 = Observable.create(() => {}).subscribe(_ => {
//Must have a success callback
});
var possibleRequest2 = Observable.create(() => {}).subscribe(_ => {
//Must have a success callback
});
var possibleRequest3 = Observable.create(() => {}).subscribe(_ => {
//Must have a success callback
});
//User 1 might need to make requests 1 and 2
var dynamicRequstList = [possibleRequest1, possibleRequest2];
//User 2 might need to make all three requests
var dynamicRequstList = [possibleRequest1, possibleRequest2, possibleRequest3];
zip(...dynamicRequestList)
.subscribe(() => {
//Need a callback after all requests are complete.
});
您可以使用forkJoin从rxjs。在此示例中，如何在您的问题示例中使用forkJoin。
服务
constructor(private http: HttpClient) { }
requestList1$ = new Subject();
requestList2$ = new Subject();
getDynamicRequstList1() {
forkJoin(
this.getItems1(),
this.getItems2()
).subscribe(res => this.requestList1$.next(res));
}
getDynamicRequstList2() {
forkJoin(
this.getItems1(),
this.getItems2(),
this.getItems3()
).subscribe(res => this.requestList2$.next(res));
}
getItems1(): Observable<any> {
return of({
item1: 'Item 1'
});
}
getItems2(): Observable<any> {
return of({
item1: 'Item 2'
});
}
getItems3(): Observable<any> {
return of({
item1: 'Item 3'
});
}
component.ts
constructor(private service: AppService) { }
ngOnInit() {
this.service.requestList1$.subscribe(res => console.log('RES 1:::', res))
this.service.requestList2$.subscribe(res => console.log('RES 2:::', res))
}
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句