Add a WatchAsync method.

Author: brendandburns

examples/watch/Program.cs

@@ -13,21 +13,21 @@ private static void Main(string[] args)
 
             IKubernetes client = new Kubernetes(config);
 
-            var podlistResp = client.ListNamespacedPodWithHttpMessagesAsync("default", watch: true).Result;
-            using (podlistResp.Watch<V1Pod>((type, item) =>
+            var podlistResp = client.ListNamespacedPodWithHttpMessagesAsync("tester", watch: true);
+            var watchTask = podlistResp.WatchAsync<V1Pod, V1PodList>((type, item) =>
             {
                 Console.WriteLine("==on watch event==");
                 Console.WriteLine(type);
                 Console.WriteLine(item.Metadata.Name);
                 Console.WriteLine("==on watch event==");
-            }))
-            {
-                Console.WriteLine("press ctrl + c to stop watching");
+            });
+            Console.WriteLine("press ctrl + c to stop watching");
+
+            var ctrlc = new ManualResetEventSlim(false);
+            Console.CancelKeyPress += (sender, eventArgs) => ctrlc.Set();
+            ctrlc.Wait();
 
-                var ctrlc = new ManualResetEventSlim(false);
-                Console.CancelKeyPress += (sender, eventArgs) => ctrlc.Set();
-                ctrlc.Wait();
-            }
+            watchTask.Result.Dispose();
         }
     }
 }

src/KubernetesClient/Watcher.cs

@@ -185,5 +185,17 @@ public static Watcher<T> Watch<T>(this HttpOperationResponse<T> response,
         {
             return Watch((HttpOperationResponse)response, onEvent, onError, onClosed);
         }
+
+        public static async Task<Watcher<T>> WatchAsync<T, L>(this Task<HttpOperationResponse<L>> responseTask,
+            Action<WatchEventType, T> onEvent,
+            Action<Exception> onError = null,
+            Action onClosed = null)
+        {
+            var response = await responseTask;
+
+            return Watch(response, onEvent, onError, onClosed);
+        }
+
+
     }
 }