如何在 angular2 上声明一个 observable

Question

我如何声明一个 observable 以及如何在 angular2 中向它添加数据？ 我有 5 个小时试图弄清楚如何去做。
我试过了

this.products : Observable<array>;
var object = {"item":item};
this.products.subscribe(object)

我尝试的每件事都会给我一个错误

我想使用它，因为我有一个经常更改的对象数组，并且在模板中 ngFor 没有更改值。 有什么帮助吗？

http://pastebin.com/1cFXJHHk 这是我尝试做的事情

Answer 1

@pixelbits 提供了一个很好的答案，描述了使用原始 observables 的方式。

但我认为您误解了可观察对象和反应式编程是什么。您可以先看看这个很棒的介绍：

• 您所缺少的响应式编程简介 - https://gist.github.com/staltz/868e7e9bc2a7b8c1f754

obersables 的subscribe 方法允许注册通知回调：

• 事件回调的第一个参数
• 关于错误的第二个回调
• 完成的最后一个

当然，您可以利用事件在列表中添加元素，但我不确定这是您的用例：

var someList = [];
let observable = (...)
observable.subscribe(data => {
  someList.push(data);
});

这对于 WebSockets、Firebase 等基于事件的工具/技术特别有用……上面的 observable 将链接到它们。这个答案可以为您提供有关如何使用 Firebase 实现此功能的更多详细信息：

• I need a listener to see if my notifications table (node) has changed for real time data checking

Answer 2

如果要创建 Observable（冷），可以使用 create 方法：

myEvent:Rx.Observable<{item:Item}>;
myObserver: Rx.Observer<{item:Item}>;
constructor() {
    this.myEvent = Rx.Observable.create(o=>this.myObserver = o);
}
someEvent() {
    // do something
    var $event = {item:new Item()};

    // emit the event object when something interesting happens
    if(this.myObserver)
        this.myObserver.emit($event);
}