Package com.puresoltechnologies.streaming.streams

Class CopyingOutputStream

java.lang.Object

java.io.OutputStream

com.puresoltechnologies.streaming.streams.CopyingOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class CopyingOutputStream
extends OutputStream

This output stream object is ussed to copy bytes to different destinations in parallel for auditing, parallel processing or logging.

Author:

Rick-Rainer Ludwig

Constructor Summary

Constructors

Constructor	Description
CopyingOutputStream(OutputStream... outputStreams)	This constructor instantiates the class based on an array of output streams.
CopyingOutputStream(Collection<OutputStream> outputStreams)	This constructor instantiates the class based on a Collection of output streams.

Method Summary

Modifier and Type	Method	Description
void	close()	This method closes all provided outputStreams.
void	write(int b)

Methods inherited from class java.lang.Object

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

Methods inherited from class java.io.OutputStream

flush, write, write

Constructor Detail

CopyingOutputStream

public CopyingOutputStream(OutputStream... outputStreams)

This constructor instantiates the class based on an array of output streams.

Parameters:

outputStreams - is the array of output streams to write each byte to.

CopyingOutputStream

public CopyingOutputStream(Collection<OutputStream> outputStreams)

This constructor instantiates the class based on a Collection of output streams.

Parameters:

outputStreams - is the array of output streams to write each byte to.

Method Detail

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

close

public void close()
           throws IOException

This method closes all provided outputStreams.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException