javascript - rxjs 中的 Observable 和 Subject 有什么区别？

Question

我正在经历这个blog并阅读有关 Observables 的内容，但无法弄清楚 Observable 和 Subject 之间的区别。

Answer 1

在流式编程中有两个主要接口(interface):Observable 和Observer。

Observable是给消费者的，可以转化订阅:

observable.map(x => ...).filter(x => ...).subscribe(x => ...)

Observer 是用于提供可观察源的接口(interface):

observer.next(newItem)

我们可以用Observer创建新的Observable:

var observable = Observable.create(observer => { 
    observer.next('first'); 
    observer.next('second'); 
    ... 
});
observable.map(x => ...).filter(x => ...).subscribe(x => ...)

或者，我们可以使用一个Subject，它同时实现了Observable 和Observer 接口(interface):

var source = new Subject();
source.map(x => ...).filter(x => ...).subscribe(x => ...)
source.next('first')
source.next('second')