Package io.clonecloudstore.common.standard.inputstream

Class TransferInputStream

java.lang.Object

java.io.InputStream

io.clonecloudstore.common.standard.inputstream.AbstractCommonInputStream

io.clonecloudstore.common.standard.inputstream.TransferInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class TransferInputStream
extends AbstractCommonInputStream

Field Summary

Fields inherited from class io.clonecloudstore.common.standard.inputstream.AbstractCommonInputStream

done, inputStream, ioExceptionAtomicReference, outputStream, pipedInputStream, pipedOutputStream, sizeOutput, sizeRead

Constructor Summary

Constructors

Constructor	Description
TransferInputStream(InputStream inputStream, AtomicReference<Exception> exceptionAtomicReference)

Method Summary

Modifier and Type	Method	Description
protected void	checkException()
protected OutputStream	getNewOutputStream(Object extraArgument)
void	startCopyAsync()

Methods inherited from class io.clonecloudstore.common.standard.inputstream.AbstractCommonInputStream

available, close, markSupported, read, read, read, skip, toString, transferTo

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

TransferInputStream

public TransferInputStream(InputStream inputStream,
 AtomicReference<Exception> exceptionAtomicReference)
                    throws IOException

Throws:

IOException

Method Details

getNewOutputStream

protected OutputStream getNewOutputStream(Object extraArgument)

Specified by:

getNewOutputStream in class AbstractCommonInputStream

startCopyAsync

public void startCopyAsync()

checkException

protected void checkException()
                       throws IOException

Overrides:

checkException in class AbstractCommonInputStream

Throws:

IOException