异步管道从 Observable 或 Subject 获取值？

Question

从 angular2

异步管道订阅 Observable 或 Promise 并返回它发出的最新值。当发出新值时，异步管道会标记要检查更改的组件。

就我而言，如果我希望异步订阅从 XMLHttpRequest 调用的 xhr.upload.onprogress 生成的事件。我应该创建一个主题还是 Observable？每次事件发生时，我都需要将它推送给这个（Subject 或 Observable）的所有订阅者（包括异步管道）

  xhr.upload.onprogress = (event) => {
    this._progress = Math.round(event.loaded / event.total * 100);
    this._subject.onNext(this._progress/100); // push the progress value to the async pipe who is the subscriber
  };

Answer 1

您可以使用其中任何一种，但由于您需要设置观察者并使可观察对象变热，因此需要做更多的工作来处理原始可观察对象。然后就可以使用观察者来通知了。

observer$:Observer<number>;

observable:Observable<number> = Observable.create(observer => {
  this.observer$ = observer;
}).share();

xhr.upload.onprogress = (event) => {
  this._progress = Math.round(event.loaded / event.total * 100);
  this.observer$.next(this._progress/100);
};

对于主题，情况已经如此（热并结合可观察/观察者）。请注意，您应该使用next 而不是onNext：

xhr.upload.onprogress = (event) => {
  this._progress = Math.round(event.loaded / event.total * 100);
  this._subject.next(this._progress/100);
};