org.apache.cxf.io

Class AbstractThresholdOutputStream

java.lang.Object

java.io.OutputStream

org.apache.cxf.io.AbstractWrappedOutputStream

org.apache.cxf.io.AbstractThresholdOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

Direct Known Subclasses:

HTTPConduit.WrappedOutputStream

public abstract class AbstractThresholdOutputStream
extends AbstractWrappedOutputStream

Outputstream that will buffer a certain amount before writing anything to the underlying stream. When the threshold is reached, provides a callback point to allow the subclass to update headers, replace/set the output stream, etc... Also provides a callback for when the stream is closed without it reaching the threshold.

Field Summary

Fields

Modifier and Type	Field and Description
protected LoadingByteArrayOutputStream	buffer
protected int	threshold

Fields inherited from class org.apache.cxf.io.AbstractWrappedOutputStream

allowFlush, wrappedStream, written

Constructor Summary

Constructors

Constructor and Description
AbstractThresholdOutputStream(int threshold)

Method Summary

Modifier and Type	Method and Description
void	close()
abstract void	thresholdNotReached()
abstract void	thresholdReached()
void	unBuffer()
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class org.apache.cxf.io.AbstractWrappedOutputStream

allowFlush, flush, onFirstWrite, write

Methods inherited from class java.lang.Object

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

Field Detail

threshold

protected int threshold

buffer

protected LoadingByteArrayOutputStream buffer

Constructor Detail

AbstractThresholdOutputStream

public AbstractThresholdOutputStream(int threshold)

Method Detail

thresholdReached

public abstract void thresholdReached()
                               throws IOException

Throws:

IOException

thresholdNotReached

public abstract void thresholdNotReached()
                                  throws IOException

Throws:

IOException

write

public void write(byte[] b,
                  int off,
                  int len)
           throws IOException

Overrides:

write in class AbstractWrappedOutputStream

Throws:

IOException

write

public void write(int b)
           throws IOException

Overrides:

write in class AbstractWrappedOutputStream

Throws:

IOException

unBuffer

public void unBuffer()
              throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractWrappedOutputStream

Throws:

IOException