mikehearn
val subscriptionTriggered = false busSubscriber.subscribe(...) { subscriptionTriggered = true } ... do something ... assertTrue(subscriptionTriggered)