Class InputStreamPumper

  • All Implemented Interfaces:
    java.lang.Runnable

    public class InputStreamPumper
    extends java.lang.Object
    implements java.lang.Runnable
    Copies all data from a System.input stream to an output stream of the executed process.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.io.InputStream is
      The input stream to pump from.
      private java.io.OutputStream os
      The output stream to pmp into.
      static int SLEEPING_TIME
      Sleep time in milliseconds.
      private boolean stop
      Flag to stop the stream pumping.
    • Constructor Summary

      Constructors 
      Constructor Description
      InputStreamPumper​(java.io.InputStream is, java.io.OutputStream os)
      Create a new stream pumper.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void run()
      Copies data from the input stream to the output stream.
      void stopProcessing()
      Requests processing to stop.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • SLEEPING_TIME

        public static final int SLEEPING_TIME
        Sleep time in milliseconds.
        See Also:
        Constant Field Values
      • is

        private final java.io.InputStream is
        The input stream to pump from.
      • os

        private final java.io.OutputStream os
        The output stream to pmp into.
      • stop

        private volatile boolean stop
        Flag to stop the stream pumping.
    • Constructor Detail

      • InputStreamPumper

        public InputStreamPumper​(java.io.InputStream is,
                                 java.io.OutputStream os)
        Create a new stream pumper.
        Parameters:
        is - input stream to read data from.
        os - output stream to write data to.
    • Method Detail

      • run

        public void run()
        Copies data from the input stream to the output stream. Terminates as soon as the input stream is closed or an error occurs.
        Specified by:
        run in interface java.lang.Runnable
      • stopProcessing

        public void stopProcessing()
        Requests processing to stop.