rxjs fromEvent的源代码实现分析

源代码：

 ngOnInit(): void {
    fromEvent(document, 'click')
  .pipe(
    // restart counter on every click
    map(() => interval(1000))
  )
  .subscribe(console.log);
  }

同样返回一个新的Observable：

参数target：document DOM：

使用的事件注册机制还是浏览器的原生实现：addEventListener:

点击浏览器窗口任意位置，触发handler：

传递给下一个执行链的是MouseEvent对象：

进入interval.js:

返回一个新的Observable：

intervals返回一个Observable对象，交个下一个destination处理，即我们应用程序的console.log代码：