> for (Payload payload : slicer.slice(blob.getPayload(), partSize)) {
> - MultipartPart part = uploadMultipartPart(mpu, partNumber, payload);
> - parts.add(part);
> - ++partNumber;
> + BlobUploader b =
> + new BlobUploader(mpu, partNumber++, payload);
> + parts.add(executor.submit(b));
> + }
> +
> + return completeMultipartUpload(mpu,
> Lists.newArrayList(Iterables.transform(parts, new
> Function<Future<MultipartPart>, MultipartPart>() {
> + @Override
> + public MultipartPart apply(Future<MultipartPart> input) {
Call `Futures.allAsList().get()` instead. Possibly with `Futures.getUnchecked`
to handle exceptions.
---
You are receiving this because you are subscribed to this thread.
Reply to this email directly or view it on GitHub:
https://github.com/jclouds/jclouds/pull/975/files/0b784d15fa6f35ceb82028e1823e85c31ccf513d#r68281233