如何解决如何对ConflatedBroadcastChannel进行单元测试?
我在这里有一个测试,试图验证发送到ConflatedbroadcastChannel(实验性API,我知道)的内容:
sudo apt install deb https://cloud.r-project.org/bin/linux/ubuntu bionic-cran40/
sudo apt-get upgrade r-base
但是,当我运行该代码时,我收到带有消息的IllegalStateException:“此作业尚未完成”。有人知道缺少什么吗?我也尝试过使用TestCoroutinedispatcher,但无济于事。
解决方法
如果您只想从通道中获取单个值,则可以始终使用receive
。
由于ConflatedBroadcastChannel
会缓存最新值,因此您可以像这样使用它:
@Test
fun myTest() = runBlockingTest {
val myChannel = ConflatedBroadcastChannel<String>()
myChannel.send("hello")
val subscription = myChannel.openSubscription()
val result = subscription.receive()
subscription.cancel()
assertEquals("hello",result)
}
,
因此,我想到了收到的消息,并怀疑“尚未完成的作业”是我正在执行的.consumeEach
操作。因此,为了明确起见,我将操作包装在launch(myTestCoroutineDispatcher)
中,并称为cancel
。这似乎不是测试事物的理想方法,但是考虑到测试环境并没有真正猜测您的频道何时应该停止接收事物,这是有道理的。无论如何,瞧,这可行:
@Test
fun myTest() = runBlockingTest {
val results = ArrayList<String>()
val myChannel = ConflatedBroadcastChannel<String>()
launch(testMainDispatcher) {
myChannel.openSubscription().consumeEach {
results.add(it)
cancel()
}
}
myChannel.send("hello")
assertEquals(1,results.size)
}
编辑:要获得相同结果,您可以做的另一件事是val myJob = launch {...}
,然后在测试执行结束时,调用myJob.cancel()
以达到相同的效果。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。