diff --git a/wow-core/src/test/kotlin/me/ahoo/wow/command/LocalFirstCommandBusTest.kt b/wow-core/src/test/kotlin/me/ahoo/wow/command/LocalFirstCommandBusTest.kt index df78d5c61f5..da32e1171a5 100644 --- a/wow-core/src/test/kotlin/me/ahoo/wow/command/LocalFirstCommandBusTest.kt +++ b/wow-core/src/test/kotlin/me/ahoo/wow/command/LocalFirstCommandBusTest.kt @@ -60,7 +60,12 @@ class LocalFirstCommandBusTest : CommandBusSpec() { .subscribe() } .test() - .verifyTimeout(Duration.ofMillis(100)) + .consumeNextWith { + assertThat(it.message.id, equalTo(message.id)) + assertThat(it.message.isVoid, equalTo(true)) + } + .thenCancel() + .verify() } } }