Exec.exec with callbacks. Tested

Author: netikras

kubernetes/src/main/java/io/kubernetes/client/custom/AsyncPump.java

@@ -19,11 +19,12 @@
 import java.util.function.BiConsumer;
 
 /**
- * A collection of all the 3 main pipes used in stdio: STDIN, STDOUT and STDERR. As working with the named pipes is usually carried out
- * asynchronously, this collection also provides means to initiate and handle the close() event. A close() initiator calls the
- * {@link #close(int, long)} method expressing its intent to close the communication channel. Handlers are notified of this intent and
- * its up to the handlers to decide what's to be done next. Calling {@link #close(int, long)} does not close the streams or do anything
- * else besides notifying the handlers.
+ * A collection of all the 3 main pipes used in stdio: STDIN, STDOUT and STDERR. As working with the
+ * named pipes is usually carried out asynchronously, this collection also provides means to
+ * initiate and handle the close() event. A close() initiator calls the {@link #close(int, long)}
+ * method expressing its intent to close the communication channel. Handlers are notified of this
+ * intent and its up to the handlers to decide what's to be done next. Calling {@link #close(int,
+ * long)} does not close the streams or do anything else besides notifying the handlers.
  */
 public class IOTrio {
   private InputStream stdout;
@@ -62,20 +63,22 @@ public void setStdin(OutputStream stdin) {
   /**
    * Capture the CLOSE intent and handle it accordingly.
    *
-   * @param handler the handler that's invoked when someone intends to close this communication. Multiple handlers can be registered
+   * @param handler the handler that's invoked when someone intends to close this communication.
+   *     Multiple handlers can be registered
    */
   public void onClose(BiConsumer<Integer, Long> handler) {
     closeHandlers.add(handler);
   }
 
   /**
-   * Express an intent to close this communication. This intent will be relayed to all the registered handlers and it's up to them what
-   * to do with it.
-   * @param code    proposed exit code
-   * @param timeout time in milliseconds given to terminate this communication. Negative timeout means no timeout (i.e. wait for as long
-   *                as it takes). 0 means "stop it now".
+   * Express an intent to close this communication. This intent will be relayed to all the
+   * registered handlers and it's up to them what to do with it.
+   *
+   * @param code proposed exit code
+   * @param timeout time in milliseconds given to terminate this communication. Negative timeout
+   *     means no timeout (i.e. wait for as long as it takes). 0 means "stop it now".
    */
   public void close(int code, long timeout) {
     closeHandlers.forEach(handler -> handler.accept(code, timeout));
   }
-}
+}