private class ThreadedS3Service.MultipartUploadObjectRunnable extends ThreadedStorageService.AbstractRunnable
ProgressMonitoredInputStream and can be can cancelled as the input stream is wrapped in
an InterruptableInputStream.| Modifier and Type | Field and Description |
|---|---|
private InterruptableInputStream |
interruptableInputStream |
private MultipartUpload |
multipartUpload |
private S3Object |
object |
private java.lang.Integer |
partNumber |
private BytesProgressWatcher |
progressMonitor |
private java.lang.Object |
result |
| Constructor and Description |
|---|
MultipartUploadObjectRunnable(MultipartUpload multipartUpload,
java.lang.Integer partNumber,
S3Object object,
BytesProgressWatcher progressMonitor) |
| Modifier and Type | Method and Description |
|---|---|
void |
forceInterruptCalled() |
java.lang.Object |
getResult() |
void |
run() |
forceInterruptprivate MultipartUpload multipartUpload
private java.lang.Integer partNumber
private S3Object object
private InterruptableInputStream interruptableInputStream
private BytesProgressWatcher progressMonitor
private java.lang.Object result
public MultipartUploadObjectRunnable(MultipartUpload multipartUpload, java.lang.Integer partNumber, S3Object object, BytesProgressWatcher progressMonitor)
public void run()
public java.lang.Object getResult()
getResult in class ThreadedStorageService.AbstractRunnablepublic void forceInterruptCalled()
forceInterruptCalled in class ThreadedStorageService.AbstractRunnable