Observer - 观察者

什么是一个 Observer ? Observer 是一个被 Observable 推送的值的消费者。 Observers 只是一系列回调，对应于 Observable 推送的 next 、 error 、 complete 三种类型的通知。下面的示例是一个经典的 Observer 的对象。

const observer = {
  next: x => console.log('Observer got a next value: ' + x),
  error: err => console.error('Observer got an error: ' + err),
  complete: () => console.log('Observer got a complete notification'),
};

想要使用 Observer ，需要为 Observable 的 subscribe 提供它自己。

observable.subscribe(observer);

Observer 只是具有三个回调的对象，一个对应于一个 Observable 可能推送的每种通知类型。

Observers 在 RxJs 也可能只是部分观察者。如果你不提供任何一种回调， Observable 的执行仍然将会正常执行，除了一些类型的通知将被忽略，因为它们在 Observer 中没有相应的回调。

下面的示例是一个没有 complete 回调的 Observer。

const observer = {
  next: x => console.log('Observer got a next value: ' + x),
  error: err => console.error('Observer got an error: ' + err),
};

订阅 Observable 时，你也可以只提供回调作为参数，而不必附加到 Observer 对象，像这个示例一样。

observable.subscribe(x => console.log('Observer got a next value: ' + x));

在 observable.subscribe 内部，它将使用第一个回调参数作为下一个处理程序创建一个 Observer 对象。 所有三种回调类型都可以作为参数提供。

observable.subscribe(
  x => console.log('Observer got a next value: ' + x),
  err => console.error('Observer got an error: ' + err),
  () => console.log('Observer got a complete notification')
);