fix: Watcher emits error if initial response is unsuccessful

manusa · Sep 20, 2020 · b8611d7 · b8611d7
1 parent 22f8a68
commit b8611d7
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/kubernetes-client/src/main/java/com/marcnuri/yakc/reactivex/WatchOnSubscribe.java b/kubernetes-client/src/main/java/com/marcnuri/yakc/reactivex/WatchOnSubscribe.java
@@ -84,8 +84,12 @@ public void subscribe(ObservableEmitter<WatchEvent<T>> emitter) {
           final InputStreamReader isr = new InputStreamReader(is);
           final BufferedReader br = new BufferedReader(isr)
       ) {
+        if (!response.isSuccessful()) {
+          emitter.tryOnError(
+            KubernetesException.forResponse("Error opening Watch connection", response));
+        }
         String line;
-        while (!emitter.isDisposed() && (line = br.readLine()) != null) {
+        while (response.isSuccessful() && !emitter.isDisposed() && (line = br.readLine()) != null) {
           final WatchEvent<T> next = converter
               .convert(ResponseBody.create(MediaType.get("application/json"), line));
           emitter.onNext(next);