RxJS的观察者和订阅者是同一件事吗？

Question

从这个留档：

RxJS为JavaScript引入了一个新的Push系统。可观察对象是多个值的生产者，将它们“推送”给观察者（消费者）。

订阅可观察对象类似于调用函数。

要调用可观察对象，我们应该从可观察对象本身调用subscribe（）函数，并将观察者作为可观察对象提供的数据的使用者传递，如：

observable.subscribe( { /*this is an observer*/ } );

本文件还说明：

什么是观察者？观察者是被观察者所传递价值的消费者。观察者只是一组回调，每个回调对应于被观察者发送的每种类型的通知：next、error和complete。以下是典型观察者对象的示例：

另一方面，第一份文件说：

可观察构造函数接受一个参数：订阅函数。下面的示例创建一个可观察的，每秒向订阅者发出字符串hi。

import { Observable } from 'rxjs';

const observable = new Observable(function subscribe(subscriber) {
  const id = setInterval(() => {
    subscriber.next('hi')
  }, 1000);
});

当调用可观察时。使用观察者订阅，函数subscribe in new Observable（函数subscribe（subscriber）{…}）为给定的订阅服务器运行。每个调用都是可观察的。subscribe为给定订阅者触发其自己的独立设置。

那么实体Subscriber只是在创建新的可观察对象时传递给subscribe函数的参数？如果不是，谁是订户？

观察员和订阅者是同一实体吗？如本文件所述

为什么调用的代码不可见。订阅（{observer as callbacks}）可观察对象的订阅方？与函数返回值的使用者一样，进行函数调用的代码也是如此。

Answer 1

const observer = {
  next: v => /* code for next callback*/,
  error: err => /* code for error callback*/,
  complete: () => /* code for completion callback*/
}

const subscription = {
  unsubscribe: () => /* code for unsubscribe callback */
}

const observable1 = from([1,2,3,4,5]);
const observable2 = of(1,2,3,4,5);
const observable3 = new Observable(observer => {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.next(4);
  observer.next(5);
  observable.complete();

  return { // return a subscription
    unsubscribe: () => /* code for unsubscribe callback */
  };
});

// Store a subscription 
const subscription = observable3.subscribe(observer);
// Invoke the unsubscribe callback defined by the observable.
subscription.unsubscribe();

[Subscriber]实现Observer接口并扩展订阅类。虽然Observer是用于消费可观察值的公共API，但所有观察者都会转换为订阅者。。。Subscriber是RxJS中的一种常见类型，对于实现操作符至关重要，但它很少用作公共API。

观察员和订阅者是一回事吗？有点，是吗？这取决于你问问题的具体程度。

考虑一下：

observable3.subscribe({
  next: v => /* code for next callback */
});

obsevable3.subscribe(
  v => /* code for next callback */
);

第一个是仅定义了一个observer属性的对象。第二个是简单的lambda函数。它们最终生成的用户基本相同。