You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by ad...@apache.org on 2018/12/20 13:39:39 UTC
[2/5] james-project git commit: JAMES-2624 use
CompletableFutureUtil.exceptionallyFuture instead of a hack
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 <ma...@apache.org>
Authored: Fri Dec 14 14:38:01 2018 +0100
Committer: Antoine Duprat <ad...@linagora.com>
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: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org