javascript - 如何使用 RxJs 流式传输 HostListener 事件？

Question

我找到了大量关于如何绑定(bind) Angular 的资源 HostListeners :

@HostListener('document:click', ['$event'])
handleClick(event: Event) {
     // etc
}

但是我该如何使用 RxJs 来流式传输呢？

documentClickedStream = Observable.fromEvent(/* how to bind this? */)

不确定如何使用 Angular 文档中建议的装饰器模式绑定(bind)以创建“随处点击”流。

Answer 1

我想最简单的方法就是使用一个中介主题:

  @HostListener('document:click', ['$event'])
  onKeyUp(e:Event) {
      this.clickStream$.next(e);
  }

然后像往常一样加入它

  this.clickStream$
      .asObservable()
      .pipe(
          // some operators...
      )
      .subscribe();