关于rxjs:RxJs-fromEvent-工作原理分析

4次阅读

共计 1523 个字符,预计需要花费 4 分钟才能阅读完成。

fromEvent(this.test, 'click').subscribe((event) => console.log(event));

this.test 的赋值逻辑:

this.test = this.document.getElementById('test');

每当该 id 为 test 的按钮被点击一次,则 fromEvent issue 一个新的值,内容为 MouseClick 事件:

本文介绍这个神奇的 fromEvent 的工作原理。

在 rxjs/_esm2015/index.js 下能看到所有 rxjs 反对的 operators:

fromEvent 构造函数反对最多 4 个输出参数,但我的例子里,之传入了两个。因而间接进入 Observable 对象的结构逻辑:

Observable 的构造函数,只有一个输出参数,该输出参数为一个函数。这个函数是一个匿名函数,只有函数体而无函数名称。

把该匿名函数保护在 Observable 的公有属性 _subscribe 里。

fromEvent 返回一个可察看对象,调用该对象的 subscribe 办法,给其注册观察者。

上图 observerOrNext 就是咱们应用程序里,传入给 subscribe 办法的匿名函数,即应用 console.log 打印 id 为 test 的 button 被点击之后抛出的 MouseEvent 事件。

因为咱们临时没有给 fromEvent 返回的 Observable 对象指定 operator,因而第 20 行 operator 为 undefined:

调用函数 toSubscriber 创立一个新的 subscriber:

上图 nextOrObserver 就是我应用程序里指定的 console.log(event) 匿名函数,只是用 Subscriber 包了一层。

Subscriber.js 外部:Subscriber 的 destination 属性,指向了 SafeSubscriber 实例:

再回到 Observable 的 subscribe 办法。当初咱们晓得了,在其 toSubscriber 办法里,创立了一个 Subscriber 实例,其重要属性如上图 1,2,3 所示。因为没有为该 Observable 指定 operator,所以第 22 行的 IF 分支进不去,而是执行第 26 行的 else 分支。

进入 trySubscribe 办法:

_trySubscribe 是 _subscribe 办法的包裹,再加上错误处理:

文章结尾提到的 Observable 公有属性 _subscribe, 指向 fromEvent.js 第 14 行匿名函数:

当初执行该匿名函数,函数体内 setupSubscription.

如何判断传进来的变量是 EventTarget 呢?

查看其是否具备 addEventListner 和 removeEventListener 即可。

这里把 fromEvent.js 里某个 handler 函数,作为按钮点击后的事件处理函数进行注册。

留神,这里给 click 点击事件注册的,并不是咱们应用程序指定的 console.log(event), 而是 fromEvent.js 里一个外部函数,如下图所示:

当我点击 UI 的 test 按钮后,触发 click 事件,fromEvent.js 里定义的事件处理函数被调用:

还记得咱们之前提到的 toSubscriber 函数调用么?将利用程序定义的 console.log(event), 包装成 SafeSubscriber,存储到 _next 属性里。

这里,最终触发 subscriber 的公有属性 _next 指向的利用程序处理逻辑:

应用了 JavaScript function 原生的 call 办法进行调用:

最终,进入了应用程序打印代码执行,谜底就此解开:

更多 Jerry 的原创文章,尽在:” 汪子熙 ”:

正文完
 0