假设我们有一个Observable:
var observable = Rx.Observable
.fromEvent(document.getElementById('emitter'), 'click');
Run Code Online (Sandbox Code Playgroud)
如何使其完成(什么将触发所有订阅的观察者的onComplete事件)?
当调用Observable.create时,运行所有observer.next()调用后,是否建议调用observer.complete()?同样,如果我们不这样做,这个方法会被自动调用吗?完整方法之后的代码也会运行吗?
我注意到另一个与此类似的问题,但答案不足以让我确定。observer.complete() 的作用是什么?
这是一个简单的例子,
return Observer.create(observer => {
observer.next(1);
observer.next(2);
observer.complete();
console.log("some more code");
});
Run Code Online (Sandbox Code Playgroud)