Как вы называете onNext изнутри вложенного Observable

Question

Я работаю в Angular2 с TypScript.

Я создал функцию, которая создает и возвращает Observable. Внутри этого наблюдаемого, другое наблюдаемое подписывается, и я хочу позвонить onNext, когда внутренний наблюдаемый получает событие. Вот код

getImages(hashtag: string) { 

    var imagesurl = this.flickrAPI.fetchImagesByTag + hashtag; 
    return Observable.create((o) => { 
     this.httpService.get(imagesurl) 
     .map(res => { 
      console.log("res"); 
      console.log(res.json()); 
      return res.json(); 
     }) 
     .map(res => res.photos.photo[0]) 
     .subscribe((result) => { 
      console.log(result); 
      console.log(this.generateImageUrl(result)); 
      o.next(this.generateImageUrl(result)); 
     }); 
    }); 
} 

Проблема заключается в том, что я получаю сообщение об ошибке, что o не распознается. По-видимому, из своего положения внутри обратного вызова subscribe он отсоединился от переданного параметра o.

Как это исправить?

Answer 1

Rx.Observerable имеет next() способ нет onNext().