Rxjs：如何创建流

Question

在理解 Observable、Observer 和 subscribe 的过程中，我刚刚来到这个例子，无法理解这个例子，我很困惑

var observable = Rx.Observable.create(
 function(observer) {     
 observer.onNext('Simon');
 observer.onNext('Jen');  
 observer.onNext('Sergi');
 observer.onCompleted();  // We are done }
);

这里发生了什么？我们在这里创建的观察者流是什么？但是观察者是在使用 subscribe 方法订阅流时从流中接收数据的人，并且有 3 个方法 onNext、complete 和 error。

也给我举个例子。我们在其中创建了一个流、一个观察者（独立）以及这个独立的观察者如何订阅一个可观察对象。

Answer 1

文档是您了解可观察对象及其机制的入口。现在的事实是，它有时会非常密集。我建议你看看这里：

• Creating and Subscribing to Simple Observable Sequences
• learning-observable-by-building-observable Ben Lesh（RxJS 开发负责人）
• The introduction to Reactive Programming you've been missing
• Hot and Cold observables : are there 'hot' and 'cold' operators?

对您的问题的简短回答是：

• Rx.Observable.create 返回一个对象（一个可观察对象），它实现了一个接口（在文档中描述），其中包括一个subscribe 函数。当您像在.subscribe(observer) 中那样执行subscribe 函数时，您作为Rx.Observable.create 的参数传递的工厂函数将使用该observer 参数执行。在您的情况下，Simon 等值将被推送到观察者（它实现了包括onNext、onCompleted 等的观察者接口）。
• 通常使用重载形式.subscribe(function yournamehere(){...})。因此，观察者是从该函数内部创建的，其 onNext 是您传递的函数，其 onError 和 onCompleted 是默认值。
• 关于您问题的第二部分，请参阅。文档https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observer.md