Class InputStreamPumper

  • All Implemented Interfaces:
    java.lang.Runnable

    public class InputStreamPumper
    extends java.lang.Object
    implements java.lang.Runnable
    Copies all data from an 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 static org.slf4j.Logger log  
      private java.io.OutputStream os
      the output stream to pmp into
      static int SLEEPING_TIME  
      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()  
      • Methods inherited from class java.lang.Object

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

      • log

        private static final org.slf4j.Logger log
      • 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()