你如何使用 RxJS v5 return new Observable(function(observer) { ...

Question

我正在尝试用 Observables 替换我函数 return 的所有承诺。从这个post，我知道我不应该再使用"new Observable"

实现异步等待的 RxJS v5 语法是什么？

thirdFunction() {

    let _self = this;

    return new Observable(function(observer) {

        ...

        observer.next( responseargs );
        observer.complete();
    });
}

非常感谢您提供的帮助。

Answer 1

有一组方法可以为不同的用例创建可观察对象：

of - 创建一个可观察对象并直接触发具有提供值
timeout - 创建一个在一定时间后触发事件的可观察对象
interval - 创建一个在一段时间后重复触发的 observable

link 按类别列出了它们：

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

你如何使用 RxJS v5 return new Observable(function(observer) { ...

How do you return new Observable(function(observer) { ... with RxJS v5?

observable

rxjs

angular