public class GetStreamerStrategy extends BlobStrategy
BlobStrategy.ChunkEventHandler
Constructor and Description |
---|
GetStreamerStrategy(Ds3Client client,
MasterObjectList masterObjectList,
int retryAfter,
int retryDelay,
BlobStrategy.ChunkEventHandler chunkEventHandler) |
Modifier and Type | Method and Description |
---|---|
void |
blobCompleted(BulkObject bulkObject) |
java.lang.Iterable<JobPart> |
getWork() |
computeDelay, getChunkEventHandler, getClient, getMasterObjectList, getRetryAfter, getRetryDelay
public GetStreamerStrategy(Ds3Client client, MasterObjectList masterObjectList, int retryAfter, int retryDelay, BlobStrategy.ChunkEventHandler chunkEventHandler)
public java.lang.Iterable<JobPart> getWork() throws java.io.IOException, java.lang.InterruptedException
getWork
in class BlobStrategy
java.io.IOException
java.lang.InterruptedException
public void blobCompleted(BulkObject bulkObject)
blobCompleted
in class BlobStrategy