После получения ответа от вызова post api выдается ошибка => .pipe не является функцией - PullRequest
Новая
       33

После получения ответа от вызова post api выдается ошибка => .pipe не является функцией

0 голосов
/ 30 сентября 2019

Я делаю вызов API и ожидаю от него ответа, который можно передать на второй вызов API, но я получаю сообщение об ошибке

ОШИБКА TypeError: this.helperService.getPointIdbyTags (... ) [0] .pipe не является функцией

на линии .pipe (switchMap ((resarray: any) => {*

TS code 

someFunction(floor){
 floor.entities.forEach(element => {
       let desiredTempForZone;

       this.getCurrentValue(element.name).subscribe((des) => 
                      {
                         currentTempForZone = des
                       });
       console.log(currentTempForZone);
})
}

getCurrentValue(eleName){
    let roomObj = this.getRoomObj(eleName);
    let equipRef = roomObj.map(equip => equip.entities.filter(entity => entity.entities.length > 0)[0])[0];

    return this.helperService.getPointIdbyTags(this.buildings, ['current', 
             'temp'], equipRef.referenceIDs.room)[0]
              .pipe(switchMap((resarray:any)=>{
                   const res = resarray[0]
                   return  this.siteService.getHisPointData(res, 'current')
                       .pipe(
                           map(this.helperService.stripHaystackTypeMapping),
                       )
              }));
}

А потом я пытаюсь передать это на 

switchMap((resarray:any)=>{
               const res = resarray[0]
               return  this.siteService.getHisPointData(res, 'current')

1 Ответ

1 голос
/ 01 октября 2019

Похоже, что getPointIdbyTags(buildingObj: any, zoneTags: any, roomRef: string = undefined) { ... } - простая функция, которая возвращает массив. Поэтому нет необходимости использовать операторы .pipe() и .switchMap, потому что RXJS используется для упрощения создания асинхронного или обратного вызова кода .

Ваш код должен выглядеть следующим образом: 

getCurrentValue(eleName){
    let roomObj = this.getRoomObj(eleName);
    let equipRef = roomObj.map(equip => equip.entities
        .filter(entity => entity.entities.length > 0)[0])[0];

    let res = this.helperService.getPointIdbyTags(this.buildings, ['current', 
             'temp'], equipRef.referenceIDs.room)[0];

    // If this method `getHisPointData()` really makes HTTP call
    // and if it returns observable than you can use `pipe` operator
    return  this.siteService.getHisPointData(res, 'current')
                       .pipe(
                           map(this.helperService.stripHaystackTypeMapping),
                       )
                       .subscribe(s => console.log(s));

}
...