restore closeWatch

Author: rafaelri

util/src/main/java/io/kubernetes/client/informer/cache/ReflectorRunnable.java

@@ -139,13 +139,7 @@ public void run() {
           this.exceptionHandler.accept(apiTypeClass, t);
           return;
         } finally {
-          if (watch != null) {
-            try {
-              watch.close();
-            } catch (IOException e) {
-              log.warn("{}#Error while closing watcher", this.apiTypeClass, e);
-            }
-          }
+          closeWatch(watch);
         }
       }
     } catch (ApiException e) {
@@ -170,6 +164,17 @@ public void stop() {
     }
   }
 
+  private synchronized void closeWatch(Watchable<ApiType> watch) {
+    try {
+      if (watch != null) {
+        watch.close();
+        watch = null;
+      }
+    } catch (IOException e) {
+      log.warn("{}#Error while closing watcher", this.apiTypeClass, e);
+    }
+  }
+
   private String initialLoad() throws ApiException {
       ApiListType list =
           listerWatcher.list(
@@ -266,11 +271,7 @@ private void watchHandler(Watchable<ApiType> watch) {
         log.debug("{}#Receiving resourceVersion {}", apiTypeClass, lastSyncResourceVersion);
       }
     }
-    try {
-      watch.close();
-    } catch (IOException e) {
-      log.warn("{}#Error while closing watcher", this.apiTypeClass, e);
-    }
+    closeWatch(watch);
   }
 
   static <ApiType extends KubernetesObject> void defaultWatchErrorHandler(