Merge pull request #322 from brendandburns/env

Close watches more cleanly.

Author: brendandburns

util/src/main/java/io/kubernetes/client/util/Watch.java

@@ -70,6 +70,7 @@ public static class Response<T> {
   Type watchType;
   ResponseBody response;
   JSON json;
+  Call call;
 
   /**
    * Creates a watch on a TYPENAME (T) using an API Client and a Call object.
@@ -105,16 +106,17 @@ public static <T> Watch<T> createWatch(ApiClient client, Call call, Type watchTy
         throw new ApiException(
             response.message(), response.code(), response.headers().toMultimap(), respBody);
       }
-      return new Watch<>(client.getJSON(), response.body(), watchType);
+      return new Watch<>(client.getJSON(), response.body(), watchType, call);
     } catch (IOException e) {
       throw new ApiException(e);
     }
   }
 
-  private Watch(JSON json, ResponseBody body, Type watchType) {
+  private Watch(JSON json, ResponseBody body, Type watchType, Call call) {
     this.response = body;
     this.watchType = watchType;
     this.json = json;
+    this.call = call;
   }
 
   public Response<T> next() {
@@ -152,6 +154,7 @@ public void remove() {
   }
 
   public void close() throws IOException {
+    this.call.cancel();
     this.response.close();
   }
 }