如何使用 RxJS v5 返回新的 Observable(function(observer) { ..



我正在尝试用可观察量替换我的函数返回的所有承诺。从这篇文章中,我了解到我不应该再使用"new Observable"Observable.forkJoin和数组参数

RxJS v5 语法是什么来实现这一点以实现异步等待?

thirdFunction() {
    let _self = this;
    return new Observable(function(observer) {
        ...
        observer.next( responseargs );
        observer.complete();
    });
}

非常感谢您提供的帮助。

有一组方法可以为不同的用例创建可观察量:

  • of - 创建一个可观察量并使用提供的值直接触发事件
  • 超时 - 创建一个在一段时间后触发事件的可观察量
  • 间隔 - 创建一个在一段时间后重复触发的可观察量

此链接按类别提供它们的列表:

  • https://github.com/Reactive-Extensions/RxJS/blob/master/doc/gettingstarted/categories.md

最新更新