首页 > 解决方案 > 订阅 next() 调用

问题描述

许多 Oberserver 都在听它并做一些事情。我想做的是等待观察者完成,然后做其他事情。

mySubject.next();

然后等待观察者或任何东西的回调。

标签: htmlangulartypescriptrxjsobservable

解决方案


据我了解,您想发出一些东西,然后等待所有订阅者完成,然后再做其他事情。

根据Rxjs 主题定义,主题就像一个事件发射器:它是单向的。

恐怕用这种方法根本不可能实现您想要在这里实现的目标。

你应该看看ngrx-store,它让你能够调度动作和效果。


推荐阅读