相关疑难解决方法(0)

如何在RxJS中完成Observable

假设我们有一个Observable:

var observable = Rx.Observable
    .fromEvent(document.getElementById('emitter'), 'click');
Run Code Online (Sandbox Code Playgroud)

如何使其完成(什么将触发所有订阅的观察者的onComplete事件)?

javascript stream observable rxjs reactivex

10
推荐指数
2
解决办法
3万
查看次数

完成 Observable.create() 时是否需要(或推荐)observer.complete()

当调用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)

observable rxjs angular

4
推荐指数
1
解决办法
1709
查看次数

标签 统计

observable ×2

rxjs ×2

angular ×1

javascript ×1

reactivex ×1

stream ×1