rxjs Наблюдаемый .map не выполняется

Question

У меня есть следующий код, который возвращает наблюдаемый, он проверяет, является ли this.data действительным JSON, в противном случае он пытается извлечь его из url. Извлечение и все работает.

load():Observable<IStandardListOutput[]> { 

return Observable.create(observer => { 

    if (this.needsFetch) { 
    var data; 
    this.http.get(this.data) 
     .map(res => { 
     var result = res.text(); 
     // console.log(result); 
     try { 
      data = JSON.parse(result) 
     } catch (e) { 
      return Observable.of([{error:"ERROR LOADING JSON: " + this.data}]); 
     } 
     return data; 
     }).subscribe(res => { 
     observer.next(this._parse(res)); 
     observer.complete(); 
     }); 
    }else { 
    observer.next(this._parse(this.data)); 
    observer.complete(); 
    } 
}); 

}

Сейчас на карте/подписываться часть наблюдателя я следующее:

let observable$ = this.loader.load(); // <-- load method above 
observable$.map(res => { 
    console.warn ("IN MAP: " + JSON.stringify(res)); 
}); 

observable$.subscribe(res=> { 
    console.log("IN SUB: " + JSON.stringify(res)); 
    }, 
    err => { 
    console.log(JSON.stringify(err)) 
    }, 
() => { 
    console.info("COMPLETE") 
    } 
); 

То, что я вижу в выводе/консоли только "IN SUB" (подписаться) и «ПОЛНАЯ». Функция console.warn в .map никогда не выполняется.

Любая помощь высоко ценится, заранее спасибо

Answer 1

карта никогда не выполняется, поскольку она создает наблюдаемую, что не остается холодной (без подписки). Добавить пустой subscribe(), и он должен работать.

observable$.map(res => { 
    console.warn ("IN MAP: " + JSON.stringify(res)); 
}).subscribe(); 

И еще один совет по отладке rxjs, если вы хотите заглянуть в значение, вы всегда можете использовать do оператора (вместо вашего map).

observable$ 
    .do((v) => console.log('debug point: ', v)) // <-- this is the addition. 
    .subscribe(...your original handlers go here ...)