Avoid null pointer exceptions

dani8art · dani8art · commit 2b106e4ccb19 · 2022-09-13T10:48:53.000+02:00
Signed-off-by: Daniel Arteaga Barba &lt;darteaga@vmware.com&gt;
diff --git a/extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlExec.java b/extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlExec.java
@@ -21,6 +21,7 @@
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
+import java.util.Optional;
 import java.util.function.Consumer;
 
 public class KubectlExec extends Kubectl.ResourceAndContainerBuilder<V1Pod, KubectlExec>
@@ -82,7 +83,7 @@ public void run() {
                 try {
                   Streams.copy(in, out);
                 } catch (IOException ex) {
-                  onUnhandledError.accept(ex);
+                  Optional.ofNullable(onUnhandledError).orElse(Throwable::printStackTrace).accept(ex);
                 }
               }
             });
diff --git a/extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlPortForward.java b/extended/src/main/java/io/kubernetes/client/extended/kubectl/KubectlPortForward.java
@@ -25,6 +25,7 @@
 import java.net.Socket;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Optional;
 import java.util.function.Consumer;
 
 public class KubectlPortForward
@@ -111,7 +112,7 @@ public void run() {
                     t1.join();
                     t2.join();
                   } catch (InterruptedException | IOException ex) {
-                    onUnhandledError.accept(ex);
+                    Optional.ofNullable(onUnhandledError).orElse(Throwable::printStackTrace).accept(ex);
                   }
                 }
               }

Original file line number	Diff line number	Diff line change
`@@ -25,6 +25,7 @@`
`25`	`25`	`import java.net.Socket;`
`26`	`26`	`import java.util.ArrayList;`
`27`	`27`	`import java.util.List;`
	`28`	`+import java.util.Optional;`
`28`	`29`	`import java.util.function.Consumer;`
`29`	`30`
`30`	`31`	`public class KubectlPortForward`
`@@ -111,7 +112,7 @@ public void run() {`
`111`	`112`	`t1.join();`
`112`	`113`	`t2.join();`
`113`	`114`	`} catch (InterruptedException \| IOException ex) {`
`114`		`- onUnhandledError.accept(ex);`
	`115`	`+ Optional.ofNullable(onUnhandledError).orElse(Throwable::printStackTrace).accept(ex);`
`115`	`116`	`}`
`116`	`117`	`}`
`117`	`118`	`}`