import org.hamcrest.MatcherAssert.*
import org.hamcrest.Matchers.*
import java.util.concurrent.atomic.*
+import java.util.function.*
import kotlin.test.*
/**
private val webOfTrustReachable = AtomicBoolean()
private val webOfTrustReacher = Runnable { webOfTrustReachable.get().onFalse { throw PluginException() } }
private val rescheduled = AtomicBoolean()
- private val reschedule = Runnable { rescheduled.set(true) }
+ private val reschedule: Consumer<Runnable> = Consumer { if (it == pinger) rescheduled.set(true) }
private val pinger = WebOfTrustPinger(eventBus, webOfTrustReacher, reschedule)
@Test
private class WebOfTrustAppearedCatcher(private val received: () -> Unit) {
@Subscribe
- fun webOfTrustAppeared(webOfTrustAppeared: WebOfTrustAppeared) {
+ fun webOfTrustAppeared(@Suppress("UNUSED_PARAMETER") webOfTrustAppeared: WebOfTrustAppeared) {
received()
}
}
private class WebOfTrustDisappearedCatcher(private val received: () -> Unit) {
@Subscribe
- fun webOfTrustDisappeared(webOfTrustDisappeared: WebOfTrustDisappeared) {
+ fun webOfTrustDisappeared(@Suppress("UNUSED_PARAMETER") webOfTrustDisappeared: WebOfTrustDisappeared) {
received()
}
}