订阅方法中的三个回调函数如何作为一个对象接收？

Question

我们做了一些可观察的之后

let observable = new Observable(observer => {
      let x = 5;
      if (x == 15) {
        observer.error('something went wrong');
      } else {
        observer.next('produce some value');
      }
      observer.complete();
    });

从观察者那里订阅这三个回调函数有不同的方式。

observable.subscribe(
      function next(data) {
        console.log(data);
      },
      function error(err) {
        console.log(err);
      },
      function complete() {
        console.log('done');
      }
    )

或者用箭头函数代替function关键字

observable.subscribe(
      x => 
      {
      console.log(x);
      },
      err => 
      {
        console.log(err);
      },
      () => 
      {
        console.log('done');
      },

这两种方式都有效 - 所以在订阅方法的最后，我们以三种方式结束 从观察者那里获取值的函数。

但是当我写例子时

observable.subscribe({
      next: (data) => console.log(data),
      error: (err) => console.log(err),
      complete: () => console.log('done')
    })

它仍在工作。但我不明白它是如何工作的，因为这里我们有三个功能 在一个物体内。在前面的两个示例中，我们直接使用了三个函数。

我的问题是当函数被“包装”在一个对象中时它是如何以及为什么工作的？

Answer 1

这是一个订阅的伪代码实现

subscribe(...args){
  let observer = {
    next: _ => {/* Do nothing */},
    error: err => { throw err },
    complete: () => {/* Do nothing */}
  }

  if(isAFunction(args[0])) observer.next = args[0];
  if(isAFunction(args[1])) observer.error = args[1];
  if(isAFunction(args[2])) observer.complete = args[2];

  if(isAnObject(args[0])){
    const partialObserver = args[0];
    if(isAFunction(partialObserver.next)) observer.next = partialObserver.next;
    if(isAFunction(partialObserver.error)) observer.error = partialObserver.error;
    if(isAFunction(partialObserver.complete)) observer.complete = partialObserver.complete;
  }

  return this._subWithObserver(observer);
}

显然，这不是完整的故事，但它是关于如何完成的一个想法。您可以深入研究源代码，了解部分观察者和/或函数如何映射到适当的观察者。

在幕后，error 和 complete 实际上是为了确保遵守 Observable 合约。