Package io.clonecloudstore.test.server.service

Class FakeStreamHandlerAbstract<I,O>

java.lang.Object

io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract<I,O>

io.clonecloudstore.test.server.service.FakeStreamHandlerAbstract<I,O>

@Dependent
public abstract class FakeStreamHandlerAbstract<I,O>
extends StreamHandlerAbstract<I,O>

Field Summary

Fields inherited from class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

countDownLatch, exceptionAtomicReference, resultProxy

Constructor Summary

Constructors

Constructor	Description
FakeStreamHandlerAbstract()

Method Summary

Modifier and Type	Method	Description
protected void	checkPushAble(I apiBusinessIn, io.clonecloudstore.common.standard.inputstream.MultipleActionsInputStream inputStream)
protected O	getAnswerPushInputStream(I apiBusinessIn, String finalHash, long size)
protected abstract O	getBusinessOutForPushAnswer(I apiBusinessIn, String finalHash, long size)
protected abstract long	getLengthFromBusinessIn(I businessIn)
protected InputStream	getPullInputStream(I apiBusinessIn)

Methods inherited from class io.clonecloudstore.common.quarkus.server.service.StreamHandlerAbstract

checkDigestToCompute, checkEndOfPush, checkPullAble, clear, doGetInputStream, endPush, getBusinessIn, getCloser, getHeaderError, getHeaderPullInputStream, getHeaderPushInputStream, getInputStreamLength, getOpId, getOriginalHash, getRequest, getServerStreamHandlerResponseException, getVertx, isAlreadyCompressed, isExternal, isKeepAlive, isKeepInputStreamCompressed, isResponseCompressed, isUpload, postSetup, preparePull, pull, pullList, sendError, sendError, setKeepInputStreamCompressed, setResponseCompressed, setResultFromRemote, setup, shallCompress, shallDecompress, throwTrappedException, upload

Methods inherited from class java.lang.Object

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

Constructor Details

FakeStreamHandlerAbstract

public FakeStreamHandlerAbstract()

Method Details

checkPushAble

protected void checkPushAble(I apiBusinessIn,
 io.clonecloudstore.common.standard.inputstream.MultipleActionsInputStream inputStream)
                      throws CcsClientGenericException,
CcsServerGenericException

Specified by:

checkPushAble in class StreamHandlerAbstract<I,O>

Throws:

CcsClientGenericException

CcsServerGenericException

getBusinessOutForPushAnswer

protected abstract O getBusinessOutForPushAnswer(I apiBusinessIn,
 String finalHash,
 long size)

getAnswerPushInputStream

protected O getAnswerPushInputStream(I apiBusinessIn,
 String finalHash,
 long size)
                              throws CcsClientGenericException,
CcsServerGenericException

Specified by:

getAnswerPushInputStream in class StreamHandlerAbstract<I,O>

Throws:

CcsClientGenericException

CcsServerGenericException

getLengthFromBusinessIn

protected abstract long getLengthFromBusinessIn(I businessIn)

getPullInputStream

protected InputStream getPullInputStream(I apiBusinessIn)
                                  throws CcsClientGenericException,
CcsServerGenericException

Specified by:

getPullInputStream in class StreamHandlerAbstract<I,O>

Throws:

CcsClientGenericException

CcsServerGenericException