将takeUntil rxjs运算符移到单独的方法

编程问答 2022-08-10

问题描述

我的Angular应用程序中有BaseComponent类，该类为可观察对象实现了destroy$: Subject<void>。每次订阅服务时，我都会这样做：

this.myService.loadData()
    .pipe(takeUntil(this.destroy$))
    .subscribe(data => this.userData = data);

我想避免到处写.pipe(takeUntil(this.destroy$))，我想知道，有什么方法可以创建可观察的扩展方法并在那里处理takeUntil吗？例如将.pipe(takeUntil(this.destroy$))移至我的自定义方法ifAlive并使其如下所示：

this.myService.loadData()
    .isAlive()
    .subscribe(...);

有什么想法吗？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

angularextension-methodsobservablerxjstypescripttypescript