net.grinder.util

Class StreamCopier

java.lang.Object

net.grinder.util.StreamCopier

public class StreamCopier
extends Object

Class that copies from InputStreams to OutputStreams. Can be used in conjunction with an active thread - see getInterruptibleRunnable(java.io.InputStream, java.io.OutputStream).

Author:

Philip Aston

Constructor Summary

Constructors

Constructor and Description
StreamCopier(int bufferSize, boolean closeStreams) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	copy(InputStream in, OutputStream out) Copies from the input stream to the output stream until the input stream is empty or one of the streams reports an error.
InterruptibleRunnable	getInterruptibleRunnable(InputStream in, OutputStream out) Creates a InterruptibleRunnable that can be used to copy a stream with an active Thread.
Runnable	getRunnable(InputStream in, OutputStream out) Convenience version of getInterruptibleRunnable(InputStream, OutputStream) that returns a Runnable.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamCopier

public StreamCopier(int bufferSize,
            boolean closeStreams)

Constructor.

Parameters:

bufferSize - The buffer size.

closeStreams - true => ensure the streams are closed after copying.

Method Detail

copy

public void copy(InputStream in,
        OutputStream out)
          throws IOException

Copies from the input stream to the output stream until the input stream is empty or one of the streams reports an error.

Not thread safe - use multiple StreamCopier instances instead.

Parameters:

in - Input stream.

out - Output stream.

Throws:

IOException - If an IO problem occurred during the copy.

getInterruptibleRunnable

public InterruptibleRunnable getInterruptibleRunnable(InputStream in,
                                             OutputStream out)

Creates a InterruptibleRunnable that can be used to copy a stream with an active Thread.

Any exceptions that occur during processing are simply discarded.

Parameters:

in - Input stream.

out - Output stream.

Returns:

The InterruptibleRunnable.

getRunnable

public Runnable getRunnable(InputStream in,
                   OutputStream out)

Convenience version of getInterruptibleRunnable(InputStream, OutputStream) that returns a Runnable.

Parameters:

in - Input stream.

out - Output stream.

Returns:

The InterruptibleRunnable.