I have a class with a following function

class BusSubscriber {
 ...
 override fun <T : Any> subscribe(clazz: KClass<T>, callback: (Any) -> Unit) {
        compositeSubscription.add(bus.events(clazz.java).subscribe(callback))
    }
 ...
}

BusSubscriber is used by another class that subscribes and passes in a lambda

busSubscriber.subscribe(ConnectivityAvailableEvent::class) {
            view?.onConnectivityAvailable()
        }

In my test I need to verify that view.onConnectivityAvailable was called