Package com.norconex.commons.lang.io

Class CachedOutputStream

java.lang.Object

java.io.OutputStream

com.norconex.commons.lang.io.CachedOutputStream

All Implemented Interfaces:

ICachedStream, Closeable, Flushable, AutoCloseable

public class CachedOutputStream
extends OutputStream
implements ICachedStream

OutputStream wrapper that caches the output so it can be retrieved once as a CachedInputStream. Invoking getInputStream() effectively close() this stream and it can no longer be written to. Obtaining an input stream before or instead of calling the close method will not delete the cache content, but rather pass the reference to it to the CachedInputStream.

To create new instances of CachedOutputStream, use the CachedStreamFactory class. Reusing the same factory will ensure all CachedOutputStream instances created share the same combined maximum memory. Invoking one of the newOutputStream(...) methods on this class have the same effect.

The internal cache stores written bytes into memory, up to to the specified maximum cache size. If content exceeds the cache limit, the cache transforms itself into a file-based cache of unlimited size. Default memory cache size is 128 KB.

Since:

1.5

Author:

Pascal Essiembre

See Also:

CachedStreamFactory

Method Summary

Modifier and Type	Method	Description
void	close()
protected void	finalize()
Path	getCacheDirectory()	Gets the cache directory where temporary cache files are created.
CachedInputStream	getInputStream()
long	getMemCacheSize()
CachedStreamFactory	getStreamFactory()
boolean	isCacheEmpty()	Returns true if was nothing to cache (no writing was performed) or if the stream was closed.
CachedOutputStream	newOuputStream()
CachedOutputStream	newOuputStream(OutputStream os)
void	write(byte[] b, int off, int len)
void	write(int b)

Methods inherited from class java.io.OutputStream

flush, nullOutputStream, write

Methods inherited from class java.lang.Object

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

Method Detail

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

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

Overrides:

write in class OutputStream

Throws:

IOException

getInputStream

public CachedInputStream getInputStream()
                                 throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException

getCacheDirectory

public final Path getCacheDirectory()

Gets the cache directory where temporary cache files are created.

Specified by:

getCacheDirectory in interface ICachedStream

Returns:

the cache directory

getStreamFactory

public CachedStreamFactory getStreamFactory()

isCacheEmpty

public boolean isCacheEmpty()

Returns true if was nothing to cache (no writing was performed) or if the stream was closed.

Returns:

true if empty

newOuputStream

public CachedOutputStream newOuputStream(OutputStream os)

newOuputStream

public CachedOutputStream newOuputStream()

getMemCacheSize

public long getMemCacheSize()

Specified by:

getMemCacheSize in interface ICachedStream

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable