在角度上与if一致(如何使用带条件的顺序请求)

Question

我有一个调用3 http observable的事件。这些请求的顺序对我来说很重要。所以我必须使用rxjs中的concat。例如，在第一个请求中，我得到了数据并用它填充了我的局部变量值，然后我想检查其中一个局部变量的结果是否为真，然后发送下一个请求。

类似的东西：

onMyEvent(e) {
let isRoundingAdditionIsRequiered = false;
let ishavePeriodicalDiscount = false;
const api = 'api/Sales/SaleTemplate/' + e;
const firstApiGet = this.dataSourceService.generateCustomApiDataList(
'sales',
'SaleTemplate',
api
).dataList$;
const secondApi= 'api/Sales/Addition/List?$filter=AdditionCode eq "4"'
const secondApiGet= this.dataSourceService.generateCustomApiDataList(
'sales',
'SaleTemplate',
api
).dataList$;
const postApi = 'api/Sales/Contract/CalculateAllRowPrices/';
const calculatePrice = this.dataSourceService.generateCustomApiPost
('sales', 'Contract', postApi, this.entity).dataList$;
}

现在，根据firstApiGet的结果，我想将isRoundingAdditionIsRequiered设置为true。像这样：

firstApiGet.subscribe(data => { if (data.RoundingAdditionIsRequiered) {isRoundingAdditionIsRequiered =true} });

然后检查下一个请求：

if (isRoundingAdditionIsRequiered ) {
secondApi.subscribe(data => {// codes here ...})
}
// and other codes ...

这不是工作顺序，所以我必须使用concat运算符。

类似的东西

concat(firstApiGet,secondApiGet,postApi).subscribe(data=>{//...})

那么代码是什么呢？

Answer 1

您可以使用switchMap运算符。

onMyEvent(e) {
let isRoundingAdditionIsRequiered = false;
let ishavePeriodicalDiscount = false;
const api = 'api/Sales/SaleTemplate/' + e;
const firstApiGet = this.dataSourceService.generateCustomApiDataList(
'sales', 'SaleTemplate', api ).dataList$;
const secondApi= 'api/Sales/Addition/List?$filter=AdditionCode eq "4"'
const secondApiGet= this.dataSourceService.generateCustomApiDataList(
'sales', 'SaleTemplate', api ).dataList$;
const postApi = 'api/Sales/Contract/CalculateAllRowPrices/';
const calculatePrice= this.dataSourceService.generateCustomApiPost(
'sales','Contract',postApi,this.entity).dataList$;
}
firstApiGet.pipe(
switchMap( data => {
isRoundingAdditionIsRequiered = data.RoundingAdditionIsRequiered;
return isRoundingAdditionIsRequiered ? secondApiGet : of( undefined );
),
switchMap( () => calculatePrice )
).subscribe();
}