fr.gouv.vitam.common.stream

Class MultiplePipedInputStream

java.lang.Object

fr.gouv.vitam.common.stream.MultiplePipedInputStream

All Implemented Interfaces:

VitamAutoCloseable, AutoCloseable

public class MultiplePipedInputStream
extends Object
implements VitamAutoCloseable

Generate multiples InputStreams from one to many using Pipe

Constructor Summary

Constructors

Constructor and Description
MultiplePipedInputStream(InputStream source, int nbCopy) Create one MultipleInputStreamHandler from one InputStream and make nbCopy linked InputStreams

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	copy(InputStream source, PipedOutputStream[] outs)
InputStream	getInputStream(int rank) Get the rank-th linked InputStream
void	hasException()

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiplePipedInputStream

public MultiplePipedInputStream(InputStream source,
                                int nbCopy)
                         throws IOException

Create one MultipleInputStreamHandler from one InputStream and make nbCopy linked InputStreams

Parameters:

source -

nbCopy -

Throws:

IOException - if any error in IO occurs

IllegalArgumentException - if source is null or nbCopy <= 0 or global service is down

Method Detail

getInputStream

public InputStream getInputStream(int rank)
                           throws IOException

Get the rank-th linked InputStream

Parameters:

rank - between 0 and nbCopy-1

Returns:

the rank-th linked InputStream

Throws:

IOException - if any error in IO occurs

IllegalArgumentException - if rank < 0 or rank >= nbCopy

hasException

public void hasException()
                  throws IOException

Throws:

IOException - if any exception is found during multiple streams

copy

protected final void copy(InputStream source,
                          PipedOutputStream[] outs)
                   throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface VitamAutoCloseable

Specified by:

close in interface AutoCloseable