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.
    Version:
    $Id: InputStreamPumper.java 1557263 2014-01-10 21:18:09Z ggregory $
    • 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  
      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

      • 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()