### Question:
PodReadinessWatcher implements Watcher<Pod> { @Override public void onClose(KubernetesClientException cause) { if (cause != null) { synchronized (this.lock) { LOGGER.warn("Watcher stopped unexpectedly, will restart", cause); this.watch = null; start(); } } } PodReadinessWatcher(String podName, KubernetesClient kubernetesClient,
			LeadershipController leadershipController); void start(); void stop(); @Override void eventReceived(Action action, Pod pod); @Override void onClose(KubernetesClientException cause);  }### Answer:
@Test public void shouldHandleClose() { initStubs(); this.watcher.onClose(this.mockKubernetesClientException); verify(this.mockPodResource).watch(this.watcher); }
@Test public void shouldIgnoreCloseWithoutCause() { this.watcher.onClose(null); verify(this.mockPodResource, times(0)).watch(this.watcher); }