aaverin
02/17/2016, 10:53 AMclass 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