什么类似于Obiseable的Promise.resolve?

BBa*_*ger 3 observable rxjs

以下是Max Schwarzmueller在YouTube上为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)
            );
    }

}
Run Code Online (Sandbox Code Playgroud)

在此示例中,CONTACTS对象是静态JSON.这里没有必要承诺,但用于显示现实世界中服务的使用.

我非常理解它,但我正在尝试将这个想法迁移到我使用可观察而不是承诺的服务中.

我想对CONTACTS数组进行更改,然后让Observable再次发出.然后告诉所有观察者再次做他们的事情.

在一个可观察的东西,这里有什么类似于Promise.resolve?RxJS observables的文档需要大量工作.

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

Gün*_*uer 5

getContacts() {
  return Observable.of(CONTACTS);
}
Run Code Online (Sandbox Code Playgroud)

观察者在发射后将完成CONTACTS.

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