java - 如何在通量\单声道上阻止和订阅

Question

我有一个通量A，我需要编写一个方法B func()，以便该方法返回另一个通量B以便可以阻止它（用于测试目的）。但是，这个通量B已经必须订阅通量A。所以，当有人调用时：func().block(); 在测试中，那么测试应该等待通量A完成。（方法func()必须订阅A才能启动通量A 的执行）

Answer 1

使用 toFeature() 等待完成