biz.hammurapi.util
Class StreamPumper

java.lang.Object
  extended by biz.hammurapi.util.StreamPumper
All Implemented Interfaces:
java.lang.Runnable

public class StreamPumper
extends java.lang.Object
implements java.lang.Runnable

Copies all data from an input stream to an output stream.

Version:
$Revision: 1.3 $
Author:
Pavel Vlasov

Constructor Summary
StreamPumper(java.io.InputStream is, java.io.OutputStream os, ExceptionSink sink, boolean closeStreams)
          Create a new stream pumper.
 
Method Summary
 void addListener(StreamPumpListener listener, int tickSize)
           
 void removeListener(StreamPumpListener listener)
           
 void run()
          Copies data from the input stream to the output stream.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StreamPumper

public StreamPumper(java.io.InputStream is,
                    java.io.OutputStream os,
                    ExceptionSink sink,
                    boolean closeStreams)
Create a new stream pumper.

Parameters:
is - input stream to read data from
os - output stream to write data to.
Method Detail

addListener

public void addListener(StreamPumpListener listener,
                        int tickSize)

removeListener

public void removeListener(StreamPumpListener listener)

run

public void run()
Copies data from the input stream to the output stream. Creates a copy of listeners collection before pumping. addListener() and removeListener() have no effect once pumping has started. Terminates as soon as the input stream is closed or an error occurs.

Specified by:
run in interface java.lang.Runnable


Copyright © 2003 Hammurapi Group. All Rights Reserved.