java - 如何在通量\单声道上阻止和订阅
问题描述
我有一个通量A,我需要编写一个方法B func(),以便该方法返回另一个通量B以便可以阻止它(用于测试目的)。但是,这个通量B已经必须订阅通量A。所以,当有人调用时:func().block(); 在测试中,那么测试应该等待通量A完成。(方法func()必须订阅A才能启动通量A 的执行)
解决方案
使用 toFeature() 等待完成
推荐阅读
- javascript - 使用javascript从对象的动态列表中获取值
- java - 仅从命令行获取系统属性列表
- ios - 无法在 iOS 可执行文件中获取 Mach-O 文本段大小
- qliksense - Qliksense:计算分组数据的中位数
- angular - 如何在运行时动态重新创建数据网格列?
- c# - 将结构数组编组到 Ptr
- phpspreadsheet - 制作大量的excel文件
- javascript - ngDoCheck、ngAfterViewChekedd 和其他类似的 Angular Lifehooks 的性能影响
- python - 从 SQL 中检索日期时,如何将日期转换为字符串?
- c# - 为什么我的框架无法识别滑动手势?