RxJS - Convert promise chain to observable not working

Viewed 173

I'm trying to convert promise chaining:

this.tradeTypesLogicService.getList().$promise
    .then(this.filterTradeTypes)
    .then(this.setSelectedTradeType)

to an rxjs observable:

this.tradeTypesLogicService
    .getList() //returns observable now
    .pipe(mergeMap(this.filterTradeTypes), map(this.setSelectedTradeType))
    .subscribe();



protected filterTradeTypes = (tradeTypes: Array<any>) => {
    this.tradeTypes = filter(tradeTypes, (trade) => {
        if (trade.id === this.mappedItem.tradeTypeId && !trade.isActive) {
            trade.label = trade.label + " (inactive)";
            return true;
        }
        return trade.isActive;
    });
    return this.tradeTypes;
}



public setSelectedTradeType = (tradeTypes): void => {
    this.selectedTradeTypeModel = tradeTypes.find(tt => tt.id === this.mappedItem.tradeTypeId);
}

I need to pass the array that is returned from filterTradeTypes into setSelectedTradeType and it is only passing one item from that array.

0 Answers
Related