Package io.clonecloudstore.common.standard.inputstream

Class MultipleActionsInputStream

java.lang.Object

java.io.InputStream

io.clonecloudstore.common.standard.inputstream.MultipleActionsInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class MultipleActionsInputStream
extends InputStream

Constructor Summary

Constructors

Constructor	Description
MultipleActionsInputStream(InputStream inputStream)
MultipleActionsInputStream(InputStream inputStream, DigestAlgo digestAlgo)

Method Summary

Modifier and Type	Method	Description
void	asyncPipedInputStream(AtomicReference<Exception> callerExceptionAtomicReference)
int	available()
void	close()
void	compress()
void	compress(int level)
static MultipleActionsInputStream	create(InputStream inputStream)
static MultipleActionsInputStream	create(InputStream inputStream, boolean digestNeeded)
void	decompress()
String	getDigest()	Default Digest base 32
String	getDigestBase32()
String	getDigestBase64()
byte[]	getDigestValue()
long	getSourceRead()
void	invalidExceptionDuringConsumeWhileErrorInputStream(boolean valid)	Allows to prevent exception during ConsumeWhileError by enclosing call between False and True set
boolean	isDigestEnabled()
boolean	markSupported()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
long	skip(long n)
String	toString()
long	transferTo(OutputStream out)
long	waitForAllRead(long timeWaitMs)

Methods inherited from class java.io.InputStream

mark, nullInputStream, readAllBytes, readNBytes, readNBytes, reset, skipNBytes

Methods inherited from class java.lang.Object

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

Constructor Details

MultipleActionsInputStream

public MultipleActionsInputStream(InputStream inputStream)

MultipleActionsInputStream

public MultipleActionsInputStream(InputStream inputStream,
 DigestAlgo digestAlgo)
                           throws NoSuchAlgorithmException

Throws:

NoSuchAlgorithmException

Method Details

create

public static MultipleActionsInputStream create(InputStream inputStream)

create

public static MultipleActionsInputStream create(InputStream inputStream,
 boolean digestNeeded)
                                         throws NoSuchAlgorithmException

Throws:

NoSuchAlgorithmException

asyncPipedInputStream

public void asyncPipedInputStream(AtomicReference<Exception> callerExceptionAtomicReference)

compress

public void compress()
              throws IOException

Throws:

IOException

compress

public void compress(int level)
              throws IOException

Throws:

IOException

decompress

public void decompress()
                throws IOException

Throws:

IOException

getSourceRead

public long getSourceRead()

waitForAllRead

public long waitForAllRead(long timeWaitMs)

Returns:

the size if the read is over, or returns -1 if read not finished in the given time

invalidExceptionDuringConsumeWhileErrorInputStream

public void invalidExceptionDuringConsumeWhileErrorInputStream(boolean valid)

Allows to prevent exception during ConsumeWhileError by enclosing call between False and True set

read

public int read(byte[] b)
         throws IOException

Overrides:

read in class InputStream

Throws:

IOException

read

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

Overrides:

read in class InputStream

Throws:

IOException

available

public int available()
              throws IOException

Overrides:

available in class InputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class InputStream

Throws:

IOException

markSupported

public boolean markSupported()

Overrides:

markSupported in class InputStream

skip

public long skip(long n)
          throws IOException

Overrides:

skip in class InputStream

Throws:

IOException

transferTo

public long transferTo(OutputStream out)
                throws IOException

Overrides:

transferTo in class InputStream

Throws:

IOException

read

public int read()
         throws IOException

Specified by:

read in class InputStream

Throws:

IOException

getDigestValue

public byte[] getDigestValue()

Returns:

the digest value (to be called once the InputStream is over)

getDigestBase64

public String getDigestBase64()

Returns:

the digest value (to be called once the InputStream is over)

getDigestBase32

public String getDigestBase32()

Returns:

the digest value (to be called once the InputStream is over)

getDigest

public String getDigest()

Default Digest base 32

isDigestEnabled

public boolean isDigestEnabled()

toString

public String toString()

Overrides:

toString in class Object