你如何从嵌套的 Observable 内部调用 onNext答案

【问题标题】：How do you call onNext from inside a nested Observable你如何从嵌套的 Observable 内部调用 onNext
【发布时间】：2016-04-01 21:29:50
【问题描述】：

我正在使用 Typescript 在 Angular2 中工作。

我创建了一个创建并返回 Observable 的函数。在这个 Observable 内部，订阅了另一个 observable，我想在内部 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 分离。

我该如何解决这个问题？

【问题讨论】：

你能发布一个语法完整的代码sn-p吗？
@RyanCavanaugh 好的，我刚刚将其更新为整个功能

标签： typescript angular rxjs

【解决方案1】：

Rx.Observerable 具有 next() 方法而不是 onNext()。

【讨论】：

...嗯..不是根据这个视频egghead.io/lessons/rxjs-creating-an-observable
为什么在你的例子中把-1和onNext改成next？
我在尝试你的建议......奇怪的是它现在有效！所以我猜egghead 是错误的。除非您编辑您的答案，否则我无法更改我的投票，您可以进行小修改吗？