JAMES-2624 use CompletableFutureUtil.exceptionallyFuture instead of a hack
Project: http://git-wip-us.apache.org/repos/asf/james-project/repo Commit: http://git-wip-us.apache.org/repos/asf/james-project/commit/2ac1fe6a Tree: http://git-wip-us.apache.org/repos/asf/james-project/tree/2ac1fe6a Diff: http://git-wip-us.apache.org/repos/asf/james-project/diff/2ac1fe6a Branch: refs/heads/master Commit: 2ac1fe6a40e1292e0f4dc0017ef0d9a2f4db05f1 Parents: 544924a Author: Matthieu Baechler <[email protected]> Authored: Fri Dec 14 14:38:01 2018 +0100 Committer: Antoine Duprat <[email protected]> Committed: Thu Dec 20 14:38:35 2018 +0100 ---------------------------------------------------------------------- .../java/org/apache/james/blob/memory/MemoryBlobStore.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/james-project/blob/2ac1fe6a/server/blob/blob-memory/src/main/java/org/apache/james/blob/memory/MemoryBlobStore.java ---------------------------------------------------------------------- diff --git a/server/blob/blob-memory/src/main/java/org/apache/james/blob/memory/MemoryBlobStore.java b/server/blob/blob-memory/src/main/java/org/apache/james/blob/memory/MemoryBlobStore.java index 20c1fef..c76b975 100644 --- a/server/blob/blob-memory/src/main/java/org/apache/james/blob/memory/MemoryBlobStore.java +++ b/server/blob/blob-memory/src/main/java/org/apache/james/blob/memory/MemoryBlobStore.java @@ -25,12 +25,12 @@ import java.io.InputStream; import java.util.Optional; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ConcurrentHashMap; -import java.util.function.Supplier; import org.apache.commons.io.IOUtils; import org.apache.james.blob.api.BlobId; import org.apache.james.blob.api.BlobStore; import org.apache.james.blob.api.ObjectStoreException; +import org.apache.james.util.CompletableFutureUtil; import com.google.common.base.Preconditions; @@ -69,10 +69,7 @@ public class MemoryBlobStore implements BlobStore { try { return CompletableFuture.completedFuture(retrieveStoredValue(blobId)); } catch (ObjectStoreException e) { - Supplier<byte[]> throwing = () -> { - throw e; - }; - return CompletableFuture.supplyAsync(throwing); + return CompletableFutureUtil.exceptionallyFuture(e); } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
