函数参数能否拥有javascript中的方法？

Question

我试图理解RxJs的可观测性，我使用的是角度框架！我无法理解“订户函数”中实际发生了什么，它有一个名为“observer”的参数，这个参数在函数体中有一个方法，它的名称是next（）！函数参数可以拥有一个方法吗？根据哪条规则？！下一个问题是：“可观察”类中发生了什么？我认为subscriber函数返回或更准确地说，创建一个值并将其传递给可观察的实例！当我们在“customIntervalObservable”上调用subscribe方法时，它会将数据或值传递给subscribe方法吗？我说得对吗？

const customIntervalObservable = new Observable(function subscriber(
  observer
) {
  let count = 0;
  setInterval(() => {
    count++;
    observer.next(+count);
    if (count > 3) {
      observer.error(new Error("count is greater than 3"));
    }
  }, 1000);
});
this.firstObjSubs = customIntervalObservable.subscribe(
  (data: number) => {
    console.log(data);
  },
  (error) => {
    console.log(error), alert(error.message);
  }
);

}

 ngOnDestroy() {
    //this.firstObjSubs.unsubscribe();
    this.firstObjSubs.unsubscribe();
  }
}

Answer 1

函数参数可以拥有一个方法吗？

Javascript函数参数没有类型，因此您可以传递任何您想要的值——包括对象。

“可观察”类中发生了什么？

我来试试这个：

• 一个可观察的基本上只是一个包装器，围绕着一个-订阅（）-函数，它本质上描述了可观察的行为的逻辑。
• 一个可观察的有能力通知主体-或订阅者，或观察者-在其生命周期中其状态发生的变化。为此，存在一个契约，该契约声明可观察的应该调用subjectNext（）方法。这个方法应该描述主题希望如何对这些更改做出反应的逻辑。
• 当一个受试者有兴趣被可观察的通知其状态变化时，它执行可观察的订阅（）方法，将自己作为参数传递给它。这有效地为可观察的提供了在逻辑要求时调用subjectNext（）方法的能力。

要在代码中基本说明这一点，请执行以下操作：

// Function describing the observable logic.
function subscribe(observer){
  // Observable logic, including calling observer.next() as many times as the logic dictates to notify the observer of state changes.
}
// Observable wrapper.
let observable = new Observable(subscribe)
// Subject interested in being notified of the observable state changes.
let observer = {
    next(value){
        // Logic for how to react to notifications from the observable.
    }
}
// Effectively execute the observable logic.
observable.subscribe(observer)

为了简单起见，我省略了一些更次要的概念，例如主题完成（）或错误（）方法，以及可观察的订阅（）函数返回的取消订阅（）函数。

Answer 2

还有一点：

您可以将观察者视为观察可观察对象并对通知作出反应的对象。

什么通知？

• 下一步：当另一个项目被发射到可观察对象中时
• 错误：发生错误时
• 完成：当没有更多要发射的项目时

Observer是一个具有三个功能的对象：每种类型的通知一个。您可以在代码中定义观察者，如下所示。但这并不常见。

然后将该观察者对象传递到订阅中，如下所示：

更常见的情况是，您将传递下一个回调，如下面的第一个示例所示。或具有一个、两个或三个回调函数的对象，如第二个示例所示。

subscribe方法告诉可观察流开始发送其值。它本身不发出任何值。把它想象成一种流媒体服务，比如迪斯尼或hulu。您必须先订阅该服务，然后才能流式播放电影。

这有用吗？