@Test
public void shouldReconnectUponWatcherClose() {

  Mockito.reset(k8sClient);
  when(k8sClient.watchPods(any())).thenThrow(new KubernetesClientException("Forced failure")).thenReturn(podWatch);
  podWatcher.onClose(new KubernetesClientException("Forced failure"));
  executor.tick(2, TimeUnit.SECONDS);
  verify(podWatch, times(2)).close();
  verify(k8sClient, times(2)).watchPods(any());
}