Add a WatchAsync method.

Author: brendandburns

examples/watch/Program.cs

@@ -13,8 +13,8 @@ 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("default", watch: true);
+            using (podlistResp.WatchAsync<V1Pod, V1PodList>((type, item) =>
             {
                 Console.WriteLine("==on watch event==");
                 Console.WriteLine(type);

src/KubernetesClient/Watcher.cs

@@ -185,5 +185,22 @@ 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;
+
+            if (!(response.Response.Content is WatcherDelegatingHandler.LineSeparatedHttpContent content))
+            {
+                throw new KubernetesClientException("not a watchable request or failed response");
+            }
+
+            return new Watcher<T>(content.StreamReader, onEvent, onError, onClosed);
+        }
+
+
     }
 }