rxjs - 什么类似于 Observable 的 Promise.resolve？

Question

这是我在 YouTube 上为 Max Schwarzmueller 的 Angular2 教程挑选的一些代码示例:https://www.youtube.com/playlist?list=PL55RiY5tL51olfU2IEqr455EYLkrhmh3n .

import {Injectable} from "angular2/core";
import {CONTACTS} from "./mock-contact";

@Injectable()

export class ContactService {

    getContacts() {
        return Promise.resolve(CONTACTS);
    }

    insertContact(contact: Contact) {
        Promise.resolve(CONTACTS)
            .then(
                (contacts: Contact[]) => contacts.push(contact)
            );
    }

}

在此示例中，CONTACTS 对象是静态 JSON。 promise 在这里不是必需的，但用于显示现实世界中服务的使用情况。

我非常理解它，但我正在尝试将这个想法迁移到我使用可观察对象而不是 promise 的服务中。

我想更改 CONTACTS 数组，然后让 Observable 发出 .then 再次告诉所有观察者再做一次他们的事情。

在 observable 上，这里有什么类似于 Promise.resolve 的？ RxJS observables 的文档有很多需要阅读的地方。

如果这只是一个愚蠢的想法，或者有更好的方法，请告诉我。

Answer 1

与

getContacts() {
  return Observable.of(CONTACTS);
}

Observable 将在发出 CONTACTS 后完成。

另见 http://paqmind.com/posts/rxjs-error-and-completed-events-demystified/