typescript - RxJS - Konverter løfte-kæde til observable virker ikke


Jeg prøver at konvertere løftekædning:

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

til en 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);
}

Jeg har brug for at sende arrayet, der returneres fra filterTradeTypes, ind i setSelectedTradeType, og det sender kun ét element fra det array.